Kafka系列:生产消费消息测试Demo

生产消息

app/kafka/kafka_2.12-2.1.0/bin/kafka-console-producer.sh --broker-list 192.168.40.148:9092 --topic demo

消费消息

/app/kafka/kafka_2.12-2.1.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.40.148:9092  --topic demo

#从0开始消费所有消息

/app/kafka/kafka_2.12-2.1.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.40.148:9092 --from-beginning --topic demo 

Kafka系列:生产消费消息测试Demo

 

Kafka系列:生产消费消息测试Demo