我曾嘗試使用 Sarama Go 庫更新 kafka 中的分區(qū)，有人可以建議該庫是否支持此功能嗎？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) }}
1 回答
HUX布斯
TA貢獻1876條經(jīng)驗 獲得超6個贊
CreatePartitions如果您想“更新分區(qū)”（注意：分區(qū)不能在 Kafka 中減少）現(xiàn)有主題，則需要。
AlterPartitionReassignments主要用于移動現(xiàn)有分區(qū)。
- 1 回答
- 0 關注
- 109 瀏覽
添加回答
舉報
0/150
提交
取消