kafka常用命令

1.常见命令

1.创建topic
kafka-topics.sh --create --bootstrap-server node1:9092 --topic test
2.查询所有的topic
kafka-topics.sh --list --bootstrap-server node1:9092
3.查看主题的详情信息
kafka-topics.sh --describe --bootstrap-server node1:9092 --topic test
4.命令终端执行发送消息
kafka-console-producer.sh --broker-list node1:9092 --topic test
5.消费队列数据（控制台打印不包括之前数据）
kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test
6.增加分区
kafka-topics.sh --bootstrap-server node1:9092  --alter --topic test --partitions 8
7.注意的是--zookeeper 和bootstrap-server同效
kafka-topics.sh --describe --zookeeper node1:2181 --topic test
8.删除topic 
kafka-topics.sh --zookeeper node1:2181 --delete  --topic test

2.压测

kafka-topics.sh --zookeeper node1:2181 --create --topic benchmark --partitions 1 --replication-factor 1