linux上のkafkaシミュレーションクライアントがメッセージを送信、受信

Producerメッセージの生成者、すなわちメッセージのパブリッシュ
consumerメッセージの消費者、すなわちメッセージの購読
broker Kafkaはクラスタで動作し、1つ以上のサービス、すなわちbrokerから構成され得る
zookeeper協調転送
 
2つの端末を開き、1つの端末がメッセージを送信し、1つの端末がメッセージを受信する.
Producer、指定されたSocket(localhost+9092)は、生産者のメッセージがkafka、すなわちbrokerに送信されることを示す
consumer、指定されたSocket(localhost+2181)は、消費者のメッセージがzookeeper(協調転送)から来ていることを示している.
 
端末が生産者として起動すると

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

端末2は消費者

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

生産者端末でメッセージを送信すると、端末2で受信する
転載先:https://www.cnblogs.com/aresxin/p/7880339.html