我试图理解Kafka Streams Checkpointing背后的想法。它只是偏移信息的消费者端管理吗？或者还有更多？任何解释细节的链接都会有所帮助。
1l5u6lss1#
Kafka Streams中的Checkpoint用于存储状态存储的changelog主题的偏移量，因此当应用程序重启并发生状态恢复时，如果偏移量仍然有效，则restore consumer将尝试从存储在检查点文件中的此偏移量继续消耗，如果不是，则恢复过程将删除旧状态并通过从changelog主题的开头消耗来开始恢复。我在Kafka Streams文档it was added from 1.1.0中找不到任何关于检查点的内容。
restore consumer
Kafka Streams
1条答案
按热度按时间1l5u6lss1#
Kafka Streams中的Checkpoint用于存储状态存储的changelog主题的偏移量，因此当应用程序重启并发生状态恢复时，如果偏移量仍然有效，则
restore consumer将尝试从存储在检查点文件中的此偏移量继续消耗，如果不是，则恢复过程将删除旧状态并通过从changelog主题的开头消耗来开始恢复。我在
Kafka Streams文档it was added from 1.1.0中找不到任何关于检查点的内容。