代码之家 › 专栏 › 技术社区 › Karol Król

如何在一个稳定的卡夫卡消费群体中转移话题的偏移量?

kafka-consumer-api apache-kafka

Karol Król · 技术社区 · 7 年前

我尝试使用以下命令在使用者组中向后偏移主题:

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

(是的,我使用的是卡夫卡版本>1.x),因此我收到了一条消息:

错误:仅当组“xxx-0”为不活动,但当前状态稳定。

如何更改组的状态 “稳定” 到 '非活动' ?

2 回复 | 直到 7 年前

kellanburket 7 年前

这个 reset-offsets 卡夫卡消费群体的选择。sh首先检查消费者是否在该组中处于活动状态,然后再尝试向后移动偏移量。”“稳定”意味着你有一个活跃的消费者在运行。

使用 describe-groups 查看您的消费群体的选项:

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

如果您在主题的“CONSUMER-ID/HOST/CLIENT-ID”下看到一个条目,则表示您仍有一个CONSUMER在运行。一旦你关闭了让消费者保持活力的应用程序,你的消费者群体将处于非活动状态,你可以随意改变你的偏移量。

ospider 5 年前

我也遇到了同样的问题,但与kellanburket的回答相比,没有消费者再运行了。在这种情况下,我必须删除消费者组:

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

在较新版本的卡夫卡中,您可能需要使用:

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

推荐文章

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

2 年前

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

6 年前

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

6 年前

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

6 年前

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

6 年前

Javier · 使用kafka主题中的json值,并使用JQ将其写入csv文件并格式化

7 年前

Karol Król · 如何在一个稳定的卡夫卡消费群体中转移话题的偏移量?

7 年前

maxness · Spark streaming:错误StreamingContext:无法构造kafka使用者

7 年前

JJ15k · 卡夫卡分区分配协议

7 年前

Jary zhen · 日志使用kafka 0.11.0调试(“组{}的协调器发现失败,刷新元数据”,groupId)。x个

7 年前