无法使用Sarama库更新kafka中的分区

Question

我尝试过使用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)
    }
}

Answer 1

如果您想要“更新分区”(注意:不能在Kafka中缩小分区)，则需要CreatePartitions。

AlterPartitionReassignments主要用于移动现有分区。