1.模拟实验

[root@yws85 ~]# cd /opt/software/kafka/
[root@yws85 kafka]# bin/kafka-topics.sh \
> --create \
> --zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
> --replication-factor 3 \
> --partitions 3 \
> --topic g5
Created topic "g5".
[root@yws85 kafka]# ll bin
kafka-console-producer.sh 
kafka-console-consumer.sh

不知道如何使用得话

[root@yws85 kafka]# cd bin
[root@yws85 bin]#./kafka-console-producer.sh

就可以看到使用

模拟生产者

[root@yws85 kafka]#bin/kafka-console-producer.sh \
--broker-list 192.168.0.85:9092,192.168.0.86:9092,192.168.0.87:9092 \
--topic g5

模拟消费者

[root@yws85 kafka]#bin/kafka-console-consumer.sh \
--zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
--topic g5 \
--from-beginning

注意2者的区别
这时在生产者输入消息，消费者就会得到，
在未来当中，你不知道你部署的kafka是否ok，自己就需要模拟一下、
一个是发数据kafka-console-producer.sh，一个是消费数据kafka-console-consumer.sh。