无法通过Sarama库来更新Kafka中的分区

在使用 Sarama Go 库更新 Kafka 分区时，需要考虑一些限制。该库不支持直接更新分区，但支持创建分区。如果您需要“更新分区”（注意：Kafka 中无法减少分区），则需要使用 CreatePartitions。

我尝试使用 sarama go 库来更新 kafka 中的分区，有人可以建议这个库是否支持此功能吗？

func UpdateTopic_part(topicDetails *TopicInfo, con kafka.ClusterAdmin) {
    fmt.Println("update Partitions")
    topicAssignment := make([][]int32, 0, 2)

    err := con.AlterPartitionReassignments(topicDetails.Topic_name, topicAssignment)

    if err != nil {
        log.Error(err)
    }
}

正确答案

如果您想“更新分区”（注意：Kafka 中无法减少分区），则需要 CreatePartitions。

AlterPartitionReassignments 主要用于移动现有分区，与 kafka-reassign-partitions.sh 相同。该二维数组是一个 BrokerId 列表，每个 BrokerId 对应一个每个代理将存储的分区列表。

终于介绍完啦！小伙伴们，这篇关于《无法通过Sarama库来更新Kafka中的分区》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！