英文:
Unable to Update partitions in kafka using Sarama Library
问题
我已经尝试使用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)
}
}
我可以帮你翻译这段代码，但请注意，我只会翻译代码部分，不会回答关于翻译的问题。
英文:
I have tried to use the Sarama Go library to update the partitions in kafka, Can anybody suggest whether this library support this feature?
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
得分: 1
如果你想要“更新分区”（注意：Kafka中的分区无法减少）现有主题，你可以使用CreatePartitions。
AlterPartitionReassignments主要用于移动现有的分区。
英文:
You want CreatePartitions if you want to "update partitions" (note: partitions cannot be reduced in Kafka) of an existing topic.
AlterPartitionReassignments is primarily to be used for moving existing partitions around.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论