我有一个想要将consumer_group_2重命名为consumer_group的用例。我之所以这样做,是因为我想从consumer_group_2的最后一个偏移量开始消费,但我想将组id从consumer_group重命名为consumer_group_2
是否可以在Sarama消费群体中使用?
发布于 2020-12-22 23:48:04
您不能重命名消费者组。
您需要创建一个新的消费者组,并提交与其他组相同的偏移量。您需要使用以下内容:
admin.ListConsumerGroupOffsets()首先从旧组中检索偏移量admin.DeleteConsumerGroup()的OffsetCommitRequest以删除旧组https://stackoverflow.com/questions/65398497
复制相似问题