1

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

我的步骤
服务器 A
1) 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)消费者并将消息输入生产者时，消费者中没有消息出现。它只是空白。
相反，当我运行1B消费者时，我会在服务器 A 中获得大量且非常快速的错误日志流，直到我 Ctrl+C 消费者。请参阅下面
的服务器 A 上的错误日志以每秒数百次的速度流式传输
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) 谢谢

4

1 回答 1

0

是的，如果您想让您的生产者在服务器 A 上，而您的消费者在服务器 B 上，那么您的方向是正确的。

您需要在服务器 A 上运行 Broker 以使其工作。

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

其他命令是正确的。

于 2017-04-03T08:34:19.667 回答