【发布时间】：2020-12-21 19:01:00
【问题描述】：
我有一个用例，我想将consumer_group_2 重命名为consumer_group。我想这样做是因为我想从 consumer_group_2 的最后一个消费偏移量开始消费，但我想将组 ID 从 consumer_group 重命名为 consumer_group_2
Sarama消费群里可以吗？
【问题讨论】：
标签： go apache-kafka sarama
【发布时间】：2020-12-21 19:01:00
【问题描述】：
您不能重命名消费者组。
您需要创建一个新的消费者组并提交与其他组相同的偏移量。您确实使用以下内容：
-
admin.ListConsumerGroupOffsets()首先从旧组中检索偏移量 - 发送带有偏移量和新组的
OffsetCommitRequest -
admin.DeleteConsumerGroup()删除旧组
【讨论】：