一、kafka常用命令
1.创建topic
bin/kafka-topics.sh --create --topic topic_1 --partitions 4 --replication-factor 2 --zookeeper mini1:2181
// 如果配置了PATH可以省略相关命令路径，相关命令参数暂不深入，字面意思也可以大概推断。后续给出完整参数参考。
2.查看所有topic
bin/kafka-topics.sh --list --zookeeper mini1:2181
3.发送消息
bin/kafka-console-producer.sh --broker-list mini1:9092 --topic topic_1
4.消费消息
bin/kafka-console-consumer.sh --zookeeper mini1:2181 --from-beginning --topic topic_1
// 可以在Mini2上消费，是分布式的
5.删除topic
bin/kafka-topics.sh --delete --zookeeper mini1:2181 --topic topic_1
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。
6.查看topic详情
bin/kafka-topics.sh --topic topic_1 --describe --zookeeper mini1:2181