Kafka创建Topic时如何将分区放置到不同的Broker中?

在Apache Kafka中,创建Topic时,可以通过指定参数将分区放置到不同的Broker中。具体而言,可以使用--broker参数指定每个分区的leader所在的broker,例如:

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic my-topic --broker-list broker1:3030,broker2:3030,broker3:3030

上述命令中,--broker-list参数指定了三个broker,分别为broker1:3030broker2:3030broker3:3030,表示将my-topic的分区分别放置在这三个broker中。

需要注意的是,每个broker之间的端口号必须一致,否则会导致leader选举失败。此外,还需要确保每个broker上都有足够的数据存储空间和网络带宽来支持Topic的分区和消息传输。

发表评论

后才能评论