我正在运行将ktable与另一个ktable（内部联接）连接起来的程序，并将其写入输出主题 . 当我执行程序时，一切正常 . 我可以在kafka日志中看到连接的数据 . 但几分钟后，日志文件中的数据就消失了 . 00000000xxx.log文件变为零字节 . 数据是否移动到其他地方？我需要做任何配置设置 . 我正在观察此行为仅适用于我用于创建ktables的主题 . 知道数据在几分钟后从主题中消失的原因吗？谢谢您的帮助 .
我正在运行的程序来自https://github.com/ftrossbach/crossing-the-streams/blob/master/src/main/java/de/codecentric/kafka/streams/InnerJoinTable.java