我尝试这样查询本地窗口状态存储：
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主题名--config retention.ms=86400000
Kafka仍然没有保留旧数据。
2条答案
按热度按时间2ul0zpep1#
我想您是在寻找窗口保留，而不是日志保留。如果是这样，您可以在这里找到如何根据自己的喜好配置它http://docs.confluent.io/current/streams/developer-guide.html#windowing
nzkunb0c2#
检查此设置
log.retention.bytes查看是否在删除特定大小的数据。保留策略也可以基于大小。