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

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

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

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

zookeeper  協調轉發

 

打開兩個終端 一個終端發送消息 一個終端接收消息：

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

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

 

終端一啟動為生產者

# ./kafka-console-producer.sh --broker-list kafkaserver:9092 --topic topicn_ame

終端二為消費者

 #./kafka-console-consumer.sh --zookeeper zookeeperserver:2181 --topic topic_name --from-beginning

 在生產者終端發送消息，會在終端二收到