如何將消息從Apache Kafka服務器發送到其他服務器？

我的兩個虛擬機上安裝Apache卡夫卡與下面的IP地址： 192.168.44.128（A）和192.168.44.129（B）如何將消息從Apache Kafka服務器發送到其他服務器？

從PC-A，我創建PC-B，它成功的話題。我用這個命令：

bin/kafka-topics.sh --create --zookeeper 192.168.44.129:2181 --replication-factor 1 --partitions 1 --topic abc

然後，我想從PC-A發送消息給PC-B，它沒有任何錯誤，但我不能得到B.消息請幫助我。

我使用這個命令，發送和獲取消息：

On PC-A 
> bin/kafka-console-producer.sh --broker-list 192.168.44.129:9092 --topic abc 
Hello 
How are you?? 
On PC-B 
> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic abc --from-beginning

來源

2016-05-11 lam nguyen

我假設你正在運行在PC-''分開和zookeeper''kafka'服務器A'和'PC-B'。如果您可以從'PC-A'訪問'PC-B'的zookeeper和kafka，那麼您可以成功創建，製作，使用和刪除'PC-A'上的主題。因此，請確保您可以通過'PC-A'產生信息到'PC-B'！ – avr

嘗試以下操作：

On PC-A 
> bin/kafka-console-producer.sh --broker-list 192.168.44.128:9092 --topic abc 
Hello 
How are you?? 
On PC-B 
> bin/kafka-console-consumer.sh --zookeeper 192.168.44.129:2181 --topic abc --from-beginning

來源

2017-01-18 08:54:52 user4342532

如何將消息從Apache Kafka服務器發送到其他服務器？

回答

相關問題