【发布时间】:2018-11-29 18:05:58
【问题描述】:
我已经建立了一个包含 3 个节点的 AWS 集群。我已经修改了节点的 /etc/hosts 文件,看起来像这样
172.31.9.2 kafka1
172.31.9.2 zookeeper1
172.31.19.230 kafka2
172.31.19.230 zookeeper2
172.31.35.20 kafka3
172.31.35.20 zookeeper3
当我从其中一个节点运行命令时
bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic first_topic --from-beginning
它可以工作,但是当我用 ip 替换主机名并使用以下命令运行它时
bin/kafka-console-consumer.sh --bootstrap-server 172.31.9.2:9092 --topic first_topic --from-beginning
它不起作用。我需要更改某些配置吗?
【问题讨论】:
-
你在哪里运行
kafka-console-consumer?节点,还是其他地方(例如您的本地机器)? -
我从托管 kafka 的节点之一运行
标签: apache-kafka kafka-consumer-api