为什么具有内存中键值存储的 GlobalKTable 在重启时不会被填充？
Why would GlobalKTable with in-memory key-value store not be filled out at restart?
我试图弄清楚 GlobalKTable 是如何工作的，并注意到我在内存中的键值存储没有被填充以防重新启动。但是，文档听起来是在重新启动的情况下填充的，因为整个数据在客户端上都是重复的。
当我调试我的应用程序时，看到 /tmp/kafka-streams/category-client-1/global/.checkpoint 上有一个文件，它包含关于我的主题的偏移量。这对于持久保存数据并改进重启的商店来说可能是必要的，但是由于此文件中存在偏移量，我的应用程序会跳过恢复其状态。
我如何确保每次重新启动或重新开始都包含我的主题的全部数据？
因为您正在使用 in-memory 商店，我假设您遇到了这个错误：https://issues.apache.org/jira/browse/KAFKA-6711
作为解决方法，您可以删除全局存储的本地检查点文件——这将在重新启动时触发引导。或者你切换回默认的 RocksDB 存储。
我试图弄清楚 GlobalKTable 是如何工作的，并注意到我在内存中的键值存储没有被填充以防重新启动。但是，文档听起来是在重新启动的情况下填充的，因为整个数据在客户端上都是重复的。
当我调试我的应用程序时，看到 /tmp/kafka-streams/category-client-1/global/.checkpoint 上有一个文件，它包含关于我的主题的偏移量。这对于持久保存数据并改进重启的商店来说可能是必要的，但是由于此文件中存在偏移量，我的应用程序会跳过恢复其状态。
我如何确保每次重新启动或重新开始都包含我的主题的全部数据？
因为您正在使用 in-memory 商店，我假设您遇到了这个错误：https://issues.apache.org/jira/browse/KAFKA-6711
作为解决方法，您可以删除全局存储的本地检查点文件——这将在重新启动时触发引导。或者你切换回默认的 RocksDB 存储。