Kafka州立商店忘记旧数据？
我尝试像这样查询我的本地窗口状态存储：
long timeFrom = 0;
long timeTo = System.currentTimeMillis();
WindowStoreIterator<Long> iterator = windowStore.fetch("topic name", timeFrom, timeTo);
我只得到大约36个小时的窗口数据回来，但想要回到过去很远。
在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中了解如何根据自己的喜好配置它
-
我有一个在多个实例上运行的kafka应用程序，我想使用state store缓存几个数据字段。在多个应用程序实例的情况下，如果一个实例发生故障，是否会将一个实例的本地状态存储复制到另一个实例？当实例返回时会发生什么？如何将状态存储连接到数据密钥以进行适当的重新分配？
-
商店数据接口 - GetShops 获取商店列表 可根据名称模糊查询返回商店列表 Request Parameters Parameter name Type Description Required search_word string 名称模糊查询，如果为空，返回所有平台 No per int 分页每页容量，如果为空，默认为10，最大数应该小于200 No page int 分页第几页，如果为
-
我想在谷歌地图上存储一些POI（兴趣点），只在android应用程序中使用 然后我想检索用户当前位置“x”km范围内的所有POI 所以，问题是：是否有可能将自定义数据存储在谷歌地图上供应用程序私人使用？（请提供任何示例的链接） 要存储的任何其他完全管理的解决方案
-
我一直在研究这个问题，在提交我的代码后，7个案例通过了，然而，9个案例失败了。问题链接位于HackerRank:电子商店 问题陈述 一个女孩想买一个键盘和一个USB驱动器，她想尽可能多地花钱，但要在预算内（将这两个项目结合起来）。如果这两件物品的价格都超过了她的预算，那么退货-1，否则她就买不到了。强制性的是，她想买这两件东西，而不是一件。 例子 一系列键盘以数组的形式给出，USB驱动器以。现在，
-
URL release环境： https://skill.rokid.com/storev2
-
URL release环境： https://skill.rokid.com/storev2/ 参数说明： 参数 说明 header 0:隐藏标题栏；1:显示标题栏 newview 0:在当前页面打开链接；1:使用新的页面打开链接 快速接入说明 1、必须 继承 SDKWebview 2、必须实现 如下 方法。 例子: Kotlin // 当前 Webview 打开一个新页面 ove