apache-kafka - 了解卡夫卡检查点

Question

我想了解 Kafka Stream Checkpointing 背后的想法。它只是消费者方面管理偏移信息吗？或者还有更多。任何解释细节的链接都会有所帮助。

Answer 1

Kafka Streams 中的 Checkpoint 用于存储 state store 的 changelog topic 的偏移量，因此当应用程序重新启动并发生状态恢复时，restore consumer 将尝试从存储在 checkpoint 中的这个偏移量继续消费如果偏移量仍然有效，则恢复文件，否则恢复过程将删除旧状态并通过从更改日志主题的开头开始消费来开始恢复。

我在 Kafka Streams 文档中找不到任何关于检查点的信息，it was added from 1.1.0 .