Kafka学习之Replication tools之Add Partition Tool
原文链接：https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-5.AddPartitionTool此工具能做啥?
Kafka的partition表示并发度的单元：一个topic的消息可以分布到多个partition上，并存储在多个server上。一旦创建了一个topic，就要指定这个topic的partition数。在topic的数据量增加时需要增加更多的partition，此工具帮助我们为某个指定的topic增加更多的partition，并可以手动的为增加的partition分配replica。此工具现在只在0.8分支提供。
如何使用？
bin/kafka-add-partitions.sh
Option Description
------ -----------
--partition <Integer: # of partitions>REQUIRED: Number of partitions to add
to the topic
--replica-assignment-list For manually assigning replicas to
<broker_id_for_part1_replica1 : brokers for the new partitions
broker_id_for_part1_replica2, (default: )
broker_id_for_part2_replica1 :
broker_id_for_part2_replica2, ...>
--topic <topic> REQUIRED: The topic for which
partitions need to be added.
--zookeeper <urls> REQUIRED: The connection string for
the zookeeper connection in the form
host:port. Multiple URLS can be
given to allow fail-over.
页:
[1]