Kafka:使消费群体不活跃

s1ag04yj  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(611)

我正在运行一个数据管道,以便通过jdbc connect将数据从sqldb读入kafka主题我使用kafka sink connector for es在elasticsearch中接收这些数据
我需要重新设置这个管道。为此,我想重置监听jdbc connect主题的使用者组。所以我运行以下命令

kafka-consumer-groups --reset-offsets --to-earliest --all-topics --execute --group mygroup --bootstrap-server myserver:9092

但我有个错误

Error: Assignments can only be reset if the group 'mygroup' is inactive, but the current state is Stable.

我停止了连接以使组处于非活动状态,但这不起作用。所以我的问题是,如何让我的团队不活跃

olhwl3o2

olhwl3o21#

--reset-offsets 在重置偏移之前,需要检查耗电元件当前是否处于活动状态。 Stable 指示耗电元件当前处于活动状态,因此偏移量不能移回。

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group mygroup --describe

应该给任何活跃的消费群体(如果有的话)。输出将帮助您确定哪些应用程序当前处于活动状态。一旦让消费者保持活跃的应用程序被终止,你就可以重置补偿。
或者,如果您使用的是旧使用者,则可以通过运行

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --group mygroup --delete

最后重置偏移量。

相关问题