[x] 生产者kafka-console-producer.sh
--broker-list指定borker
[x] 消费者
--from-beginning 读取历史未消费的数据(consumer重启后还可以继续消费指定tiopic中没有消费的数据)
[x] kafka中的消息是以topic作为区分的,生产者生产消息和消费者消费消息都是面向topic的。
[x] 生产者kafka-console-producer.sh
--broker-list指定borker
[x] 消费者
--from-beginning 读取历史未消费的数据(consumer重启后还可以继续消费指定tiopic中没有消费的数据)
[x] kafka中的消息是以topic作为区分的,生产者生产消息和消费者消费消息都是面向topic的。