我试图理解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中找不到任何关于检查点的内容。