我曾嘗試使用 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) }}
添加回答
舉報
0/150
提交
取消