小编Sye*_*yun的帖子

再次重新处理/读取 Kafka 记录/消息 - 消费者组偏移重置的目的是什么?

我的 kafka 主题总共有 10 条记录/消息,2 个分区,每个分区有 5 条消息。我的消费者组有 2 个消费者,每个消费者已经分别从他们分配的分区中读取了 5 条消息。现在,我想从开始/开始(偏移量 0)重新处理/读取来自我的主题的消息。

我停止了我的 kafka 消费者并运行以下命令将消费者组偏移量重置为 0。

./kafka-consumer-groups.sh --group cg1 --reset-offsets --to-offset 0 --topic t1 --execute --bootstrap-server "..."
Run Code Online (Sandbox Code Playgroud)

我的期望是,一旦我重新启动我的 kafka 消费者,他们将开始从偏移量 0 即开始读取记录,但这并没有发生,他们从最后一个位置(即偏移量 5)进行轮询。为什么会这样?然后我必须让我的每个消费者明确地寻求偏移 0(开始)以从头开始重新处理/读取记录。在后来的测试周期中,我什至没有运行上面的命令来重置 kafka 消费者组的偏移量。

我的问题是,如果我必须让我的消费者明确地寻求开始让他们再次重新处理/读取消息,那么重置 kafka 消费者组的偏移量的目的是什么?

apache-kafka kafka-consumer-api

4
推荐指数
1
解决办法
4684
查看次数

标签 统计

apache-kafka ×1

kafka-consumer-api ×1