--1.创建topic主题 kafka-topics.sh --create --zookeeper had01:2181,had02:2181,had03:2181 --replication-factor 3 --partitions 3 --topic test_shell --2.在had01执行生产者的命令 kafka-console-producer.sh --broker-list had01:9092 --topic test_shell --3.在had02执行消费者的命令 kafka-console-consumer.sh --bootstrap-server had01:9092 --topic test_shell --from-beginning
