1.topic相关
1.1 查看kafka集群的所有topic
./bin/kafka-topics.sh --list --zookeeper localhost:2181
1.2 创建名称为topic_test的topic,patitions为1个，副本为1个
.bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --patitions 1 --topic topic_test
1.3 为topic_test添加patition为10
.bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic_test --partitions 10
1.4 删除名称为topic_test的topic(只删除zookeeper内的元素，消失文件须手动删除)
.bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic topic_test
1.5 查看topic为topic_test的详细信息
.bin/kafka-topics.sh --zookeeper localhost:2181 -describe -topic topic_test
2.consumer相关
2.1 查看所有consumer的group
.bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
2.2 查看group为group_test消费的机器以及partition
./bin/kafka-consumer-groups.sh --describe --group group_test --bootstrap-server localhost:9092
3.控制台相关
3.1 控制台向topic_test发送数据
.bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic_test
3.2 控制台接收topic_test数据
.bin/kafka-console-consumer.sh --bootstrap-server localhost:9002 --topic topic_test --from-beginning
4.服务相关
4.1 启动zookeeper服务
./bin/zookeeper-server-start.sh -daemon ../config/zookeeper.properties
4.2. 启动kafka服务
./bin/kafka-server-start.sh -daemon ../config/server.properties
4.3 查看服务启动
ps -ef | grep kafka