如何在稳定的卡夫卡消费者群中转移话题的偏移量？

Question

我尝试使用以下命令将使用者组内主题的偏移移回：

bin/kafka-consumer-groups.sh --bootstrap-server loclahost:9092 --group xxx-0 --topic schedule-changed --reset-offsets --shift-by -2 --execute

（是的，我正在使用kafka版本> 1.x）结果是我收到一条消息：

错误：仅当组“ xxx-0”处于非活动状态但当前状态为“稳定”时，才能重置分配。

如何将组的状态从“稳定”更改为“无效”？

Answer 1

我遇到了同样的问题，但与 kellanburket 的回答相反，没有消费者再运行了。在这种情况下，我不得不删除消费者组：

kafka-consumer-groups --zookeeper a.zookeeper.host:2181 --group the-group-name --delete

在较新版本的 kafka 中，您可能需要使用：

kafka-consumer-groups --bootstrap-server $SERVERS --group the-group-name --delete

Answer 2

reset-offsetskafka-consumer-groups.sh 的选项首先尝试查看消费者在该组中是否处于活动状态，然后再尝试移回偏移。“稳定”表示您有一个活跃的消费者在运行。

使用该describe-groups选项检查您的消费群体：

bin/kafka-consumer-groups.sh --bootstrap-server $SERVERS --group $GROUP --describe

如果您在主题的“消费者ID /主机/客户ID”下看到一个条目，则表明您仍在运行消费者。一旦您关闭了使消费者保持活力的应用程序，您的消费者群体就将处于非活动状态，并且您可以随意移动抵消额。