代码之家 › 专栏 › 技术社区 › Fizi

卡夫卡:使消费群体不活跃

apache-kafka-connect kafka-consumer-api apache-kafka

Fizi · 技术社区 · 7 年前

我使用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.

1 回复 | 直到 7 年前

Giorgos Myrianthous 7 年前

--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

最后重置偏移量。

推荐文章

Shubham Snehi · Golang Segmentation在消费者组迁移时获得一半分区

2 年前

Varun Sharma · 从Kaffa主题消费并添加到列表中

2 年前

Andrey P. · 添加spring-cloud-starter-bus-Kafka依赖项后,Kafka消费者没有收到消息

2 年前

Evgeniy Zhurenko · 为什么卡夫卡的消费者没有收到经纪人的记录

2 年前

Dev9321 · Kafka消费者组没有消费来自所有消费者的消息

3 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

4 年前

BnJ · 如何知道卡夫卡何时提交记录?

8 年前

addictedtohaskell · 为什么卡夫卡消费者无视我在汽车上的“最早”指令。抵消重置参数,从而不从绝对第一个事件读取我的主题?

8 年前

maverick · 消息预处理(主题-主题)-Kafka Connect API vs.Streams vs Kafka Consumer?

8 年前

Renato Garcia · 如何设置隔离。等级卡夫卡骆驼组件

8 年前