创建名称为test的topic且副本数量3，partition数量6

/etc/kafka/kafka/bin/kafka-topics.sh --create --bootstrap-server 10.1.60.112:9092 --replication-factor 3 --partitions 6 --topic test

查看名称为test的topic信息

/etc/kafka/kafka/bin/kafka-topics.sh --describe --bootstrap-server 10.1.60.114:9092 --topic test

查看所有topic

/etc/kafka/kafka/bin/kafka-topics.sh --list --bootstrap-server 10.1.60.112:9092

 删除topic

/etc/kafka/kafka/bin/kafka-topics.sh --bootstrap-server 10.1.60.112:9092 --delete --topic test

使用生产者脚本向名称为test的topic写入消息

/etc/kafka/kafka/bin/kafka-console-producer.sh --broker-list 10.1.60.112:9092 --topic test

使用消费者脚本消费名称为test的topic中的消息

/etc/kafka/kafka/bin/kafka-console-consumer.sh --bootstrap-server 10.1.60.114:9092 --topic test --from-beginning

 重新分配topic为apex的分区2的leader节点

/etc/kafka/kafka/bin/kafka-leader-election.sh --bootstrap-server 10.1.60.114:9092 --topic apex --partition 2 --election-type preferred

 kafka集群生产压力测试

/etc/kafka/kafka/bin/kafka-producer-perf-test.sh --topic test --record-size 1024 --num-records 1000000 --throughput -1 --producer-props bootstrap.servers=10.1.60.112:9092,10.1.60.114:9092,10.1.60.115:9092

kafka集群消费压力测试

/etc/kafka/kafka/bin/kafka-consumer-perf-test.sh --topic test --broker-list 10.1.60.112:9092,10.1.60.114:9092,10.1.60.115:9092 --fetch-size 10000 --messages 1000000 --threads 1

有不会用的命令也可以在命令后加入 --help

 例如 /etc/kafka/kafka/bin/kafka-topics.sh --help