直接生产者发送消息,但是version1-topic这个topic是之前不存在的 ### `./kafka-console-producer.sh --broker-list 10.10.15.132:9092 --topic version1-topic` ### 上述命令时向version1-topic这个topic当中发送消息,但是我们并没有事先创建version1-topic 所以kafka会为我们自动创建这个topic 并发送消息 ### 再来看消费者消费消息 ### `./kafka-console-consumer.sh --bootstrap-server 10.10.15.132:9092 --topic version1-topic` ### --topic version1-topic 指定要消费哪个topic ### ![](https://img.kancloud.cn/aa/75/aa75d0c8d0fbb48b46eee31739f3a552_1841x967.png) ### **--from-beginning会把主题中以往所有的数据都读取出来,重启消费者会重复消费topic当中的消息** ###