无法使用 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

CreatePartitions如果您想“更新分区”（注意：分区不能在 Kafka 中减少）现有主题，则需要。

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