kafka模擬客戶端發送、接受消息

producer   消息的生成者，即發布消息

consumer   消息的消費者，即訂閱消息

broker     Kafka以集群的方式運行，可以由一個或多個服務組成，服務即broker

zookeeper  協調轉發 

 

一、創建topic

./kafka-topics.sh  --create --zookeeper localhost:2181 \ --replication-factor 1\ --partitions 1\ --topic first_topic

創建完后可以使用list查看下

./kafka-topics.sh --list --zookeeper localhost:2181 first_topic

 

二、重新打開兩個終端 假設一個終端發送消息 一個終端接收消息，這里：

producer，指定的Socket(localhost+9092),說明生產者的消息要發往kafka，也即是broker

consumer, 指定的Socket(localhost+2181),說明消費者的消息來自zookeeper（協調轉發）

 

在終端9092中，啟動為提供者

./kafka-console-producer.sh --broker-list localhost:9092 --topic first_topic

在另一個終端2181中，啟動為消費者

 ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic first_topic --from-beginning

 

隨后你在9092中輸入的數據，就會在2181的控制台打印出來了~ 結束。