## 查看topic列表
bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

## 创建topic
bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 3 --topic topic-test

## 消费消息
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic  topic-test --from-beginning

## 生产消息
bin/kafka-console-producer.sh ../config/producer.properties --topic topic-test --broker-list 127.0.0.1:9092