Kafka state stores 忘记了旧数据？

Question

我尝试像这样查询本地 window 国营商店：

long timeFrom = 0;
long timeTo = System.currentTimeMillis();
WindowStoreIterator<Long> iterator = windowStore.fetch("topic name", timeFrom, timeTo);

我只能返回大约 36 小时的 windowed 数据，但想回到过去。

我尝试通过多种方式配置保留，还重新启动了我的 kafka 服务器和 zookeeper：

在config/server.properties: log.retention.hours=87600

bin/kafka-topics.sh --zookeeper zk.yoursite.com --alter --topic topicName --config retention.ms=86400000

卡夫卡仍然不保留旧数据。

Answer 1

检查此设置 log.retention.bytes 以查看您是否在删除超过特定大小的数据。保留策略也可以基于大小。

Answer 2

我认为您正在寻找 window 保留，而不是日志保留。如果是这样，您可以在此处找到如何根据自己的喜好进行配置 http://docs.confluent.io/current/streams/developer-guide.html#windowing

Kafka state stores forget old data?