基本的命令

1、创建topic

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

replication-factor,为副本数；
partitions，为分片数，分片数量最好为kafka数据路径总和的整数倍；

2、查看都有哪些topic

kafka-topics --list --zookeeper localhost:2181 

3、查看topic详情

kafka-topics --describe --zookeeper localhost:2181 --topic test 

4、删除topic

kafka-topics --zookeeper localhost:2181 --topic test --delete 

5、消费topic中的数据

从头消费

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

从输入命令起开始消费

kafka-console-consumer --bootstrap-server localhost:9092 --topic test

6、产生数据

kafka-console-producer --broker-list localhost:9092 --topic test 

7、压力测试

kafka-producer-perf-test --topic test --num-records 100 --record-size 1 --throughput 100 --producer-props bootstrap.servers=localhost:9092 

num-records，消息数量
record-size，单条消息的大小，单位为字节
throughput，多少秒一条消息，-1为没有间歇

8、平衡leader

kafka-preferred-replica-election --zookeeper zk_host:port/chroot