go - 重命名Sarama的kafka消费群?

标签 go apache-kafka sarama

我有一个用例,我想将consumer_group_2重命名为consumer_group。我想这样做是因为我想从consumer_group_2的上一个消耗偏移量开始使用,但是我想将组ID从consumer_group重命名为consumer_group_2Sarama消费群有可能吗?

最佳答案

您无法重命名使用者组。
您需要创建一个新的使用者组,并提交与其他组相同的偏移量。您确实使用以下内容:

  • admin.ListConsumerGroupOffsets()首先从旧组
  • 中检索偏移量
  • 发送带有偏移量的OffsetCommitRequest和新组
  • admin.DeleteConsumerGroup()删除旧组
  • 关于go - 重命名Sarama的kafka消费群?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65398497/

    相关文章:

    go - 为什么 Shopify Sarama 消费者需要分区来消费消息

    go - 自定义 Controller 在缓存同步之前对 addfunc 事件处理程序使用react?这种行为是否正确?

    apache-kafka - Kafka Log Compaction也是一种去重机制吗

    apache-kafka - Kafka如何并行消费一个主题

    docker - Py4JJavaError : An error occurred while calling o45. 加载。 : java. lang.NoClassDefFoundError:org/apache/spark/sql/sources/v2/StreamWriteSupport

    go - 如何使用 Sarama 在多个 goroutine 中消费 Kafka 主题?

    go - Golang 从哪里获取根 CA?

    go - 在 "go build"之前设置一个环境变量

    go - 如何使用 unmarshal 解析 gpx

    go - 消息不以魔术字节开头