【kafka】生產和消費消息

  • [x] 生產者kafka-console-producer.sh
kafka-console-producer.sh --topic test-topic-01 --broker-list 172.21.0.5:9092

--broker-list指定borkerbootstrap

  • [x] 消費者
    kafka-console-consumer.sh --topic test-topic-01 --bootstrap-server 172.21.0.5:9092

--from-beginning 讀取歷史未消費的數據(consumer重啓後還能夠繼續消費指定tiopic中沒有消費的數據)ide

  • [x] kafka中的消息是以topic做爲區分的,生產者生產消息和消費者消費消息都是面向topic的。
kafka-console-producer.sh --topic test-topic-01 --broker-list 172.21.0.5:9092
kafka-console-consumer.sh --topic test-topic-01 --bootstrap-server 172.21.0.5:9092
相關文章
相關標籤/搜索