我有一个用例,我想将consumer_group_2
重命名为consumer_group
。我想这样做是因为我想从consumer_group_2
的上一个消耗偏移量开始使用,但是我想将组ID从consumer_group
重命名为consumer_group_2
Sarama消费群有可能吗?
最佳答案
您无法重命名使用者组。
您需要创建一个新的使用者组,并提交与其他组相同的偏移量。您确实使用以下内容:
admin.ListConsumerGroupOffsets()
首先从旧组OffsetCommitRequest
和新组admin.DeleteConsumerGroup()
删除旧组关于go - 重命名Sarama的kafka消费群?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65398497/