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