在不同的服务器上消费和生成Kafka消息

mlnl4t2r 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(571)

如何生成和使用来自不同服务器的消息？我尝试了快速入门教程，但是没有关于如何设置多服务器集群的说明。
我的脚步声
服务器a

bin/zookeeper-server-start.sh config/zookeeper.properties 2) bin/kafka-server-start.sh config/server.properties 3) bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 4) bin/kafka-console-producer.sh --broker-list SERVER-a.IP:9092 --topic test 服务器b
（1a） bin/kafka-console-consumer.sh --bootstrap-server SERVER-a.IP:9092 --topic test --from-beginning （1b） bin/kafka-console-consumer.sh --bootstrap-server SERVER-a.IP:2181 --topic test --from-beginning 当我运行1a）consumer并在producer中输入消息时，consumer中没有出现消息。只是一片空白。
当我运行1b consumer时，我在服务器a中得到了一个巨大且非常快速的错误日志流，直到我ctrl+c消费者。见下文
以每秒数百次的速度登录流媒体服务器时出错
WARN Exception causing close of session 0x0 due to java.io.EOFException (org.apache.zookeeper.server.NIOServerCnxn) O Closed socket connection for client /188.166.178.40:51168 (no session established for client) (org.apache.zookeeper.server.NIOServerCnxn) 谢谢

1条答案

是的，如果你想让生产者在服务器a上，消费者在服务器b上，你的方向是正确的。
您需要在服务器上运行一个代理才能使其工作。

bin/kafka-server-start.sh config/server.properties

其他命令正确。