1

我有一个用例，我想将其重命名consumer_group_2为consumer_group. 我想这样做是因为我想从上次消费的偏移量开始消费，consumer_group_2但我想将组 ID 从重命名consumer_group为consumer_group_2

在Sarama消费群有可能吗？

4

1 回答 1

2

您不能重命名消费者组。

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

  • admin.ListConsumerGroupOffsets()首先从旧组中检索偏移量
  • 发送OffsetCommitRequest带有偏移量和新组的
  • admin.DeleteConsumerGroup()删除旧组
于 2020-12-22T15:48:03.900 回答