如何将消息从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服务器发送到其他服务器？

回答

相关问题