Kafka 状态存储忘记了旧数据？答案

【问题标题】：Kafka state stores forget old data?Kafka 状态存储忘记了旧数据？
【发布时间】：2018-02-11 06:53:39
【问题描述】：

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

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 不保留旧数据。

【问题讨论】：

【解决方案1】：

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

【讨论】：

【解决方案2】：

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

【讨论】：