如何生成和使用来自不同服务器的消息?我尝试了快速入门教程,但是没有关于如何设置多服务器集群的说明。
我的脚步声
服务器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条答案
按热度按时间olhwl3o21#
是的,如果你想让生产者在服务器a上,消费者在服务器b上,你的方向是正确的。
您需要在服务器上运行一个代理才能使其工作。
其他命令正确。