首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >在Sarama中重命名kafka消费者组?

在Sarama中重命名kafka消费者组?
EN

Stack Overflow用户
提问于 2020-12-22 03:01:00
回答 1查看 381关注 0票数 1

我有一个想要将consumer_group_2重命名为consumer_group的用例。我之所以这样做,是因为我想从consumer_group_2的最后一个偏移量开始消费,但我想将组id从consumer_group重命名为consumer_group_2

是否可以在Sarama消费群体中使用?

EN

回答 1

Stack Overflow用户

发布于 2020-12-22 23:48:04

您不能重命名消费者组。

您需要创建一个新的消费者组,并提交与其他组相同的偏移量。您需要使用以下内容:

  • admin.ListConsumerGroupOffsets()首先从旧组中检索偏移量
  • 发送带有偏移量和新group
  • admin.DeleteConsumerGroup()OffsetCommitRequest以删除旧组
票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/65398497

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档