首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Kafka-15.实现-分发

Kafka消费者跟踪它在每个分区消费的最大偏移量,并且能够提交偏移量,以便在重新启动的时候可以从这些偏移量中恢复。Kafka提供了在指定broker(针对该组)中将给定消费者组的所有偏移量存储为group coordinator的选项。即,改消费者组中的任何消费者实例应将其偏移量提交和提取发送给该group coordinator。消费者可以通过任何Kafka broker发出FindCoordinatorRequest并读取包含包含协调器详细信息的FindCoordinatorResponse来查找其协调器。然后,消费者可以继续从coordinator broker处理提交或者获取偏移量。在coordinator 移动的情况下,消费者需要重新发现coordinator。偏移调教可以由消费者实例自动或手动完成。

02
领券