Kafka创建Topic常用命令

1. 创建Topic时，一般是Kafka自动分配副本节点，命令如下：

kafka-topics.sh --create --topic <topic name> --partitions <Integer: the number of partitions> --replication-factor <Integer: replication factor> --zookeeper <ZK_IP1:ZK_PORT,ZK_IP2:ZK_PORT,.../kafka>

若忽略机架，上述命令加上 --disable-rack-aware

2. 创建Topic时，若需指定所有副本所在节点，命令如下：

kafka-topics.sh --create --topic <topic name>  --replica-assignment <String:  broker_id_for_part1_replica1:broker_id_for_part1_replica2 ,broker_id_for_part2_replica1:broker_id_for_part2_replica2 , ...>

例如：kafka-topics.sh --create --topic test1 --replica-assignment 1:2,1:2,1:2  --zookeeper zkIP:24002/kafka

具体的broker_id与节点IP对应关系可通过kafka-broker-info.sh  --zookeeper <ZK_IP1:ZK_PORT,ZK_IP2:ZK_PORT,.../kafka>命令查看

3. 创建Topic后，查看Topic的具体信息，命令如下：

查看所有topic的describe信息：

kafka-topics.sh --describe --zookeeper <ZK_IP1:ZK_PORT,ZK_IP2:ZK_PORT,.../kafka>

查看某些topic的describe信息：

kafka-topics.sh --describe --zookeeper <ZK_IP1:ZK_PORT,ZK_IP2:ZK_PORT,.../kafka> --topic <topicName1，topicName2>

例如：kafka-topics.sh --describe --zookeeper zkIP:24002/kafka --topic test,test1