apache-kafka - Kafka 状态存储忘记了旧数据？

Question

我尝试像这样查询我的本地窗口状态存储：

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

我只能得到大约 36 小时的窗口数据，但想回到过去。

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

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

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

Kafka 仍然不保留旧数据。

Answer 1

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

Answer 2

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