了解卡夫卡检查站

Question

我正在努力理解Kafka流检查点背后的想法。这只是一个消费者端的偏移信息管理吗？或者还有更多。任何解释细节的链接都会很有帮助。

Answer 1

Kafka Streams中的Checkpoint用于存储状态存储的changelog主题的偏移量，因此当应用程序重新启动并进行状态恢复时，如果偏移量仍然有效，restore consumer将尝试从存储在Checkpoint文件中的该偏移量继续消耗，如果没有，还原过程将删除旧状态，并通过从changelog主题的开头消费来开始还原。

我在Kafka Streams文档中找不到任何关于检查点的信息，它是从1.1.0添加的。