1、启动Kafka
./bin/kafka-server-start.sh ./config/server.properties &
2、停止Kafka
./bin/kafka-server-stop.sh
3、创建Topic
# 老版
./bin/kafka-topics.sh --create --zookeeper 192.168.209.102:2181 --replication-factor 2 --partitions 2 --topic test
# 新版
./bin/kafka-topics.sh --create --bootstrap-server 192.168.209.102:2181 --partitions 3 --replication-factor 2 --topic test
4、查看已经创建的Topic信息
# 老版
./bin/kafka-topics.sh --list --zookeeper 10.0.12.16:2181,10.0.12.16:2182,10.0.12.16:2183
5、查看topic详情
# 老版
./bin/kafka-topics.sh --zookeeper 192.168.209.102:2181 --topic topic3 --describe
# 新版
./bin/kafka-topics.sh --bootstrap-server 192.168.209.102:2181 --describe --topic test
6、删除topic
./bin/kafka-topics.sh --zookeeper 10.0.12.16:2181,10.0.12.16:2182,10.0.12.16:2183 --topic topic1 --from-beginning--delete
7、发送消息
./bin/kafka-console-producer.sh --broker-list 43.139.86.193:9092 --topic topic1
8、接收消息
./bin/kafka-console-consumer.sh --bootstrap-server 43.139.86.193:9092 --topic topic1 --from-beginning