【问题标题】:Not able to consume messages using kafka-console-consumer.sh无法使用 kafka-console-consumer.sh 消费消息
【发布时间】: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


【解决方案1】:

在 server.properties 的 'listeners' 配置项中指定主机名时,使用 0.0.0.0 作为主机,让 kafka 更宽容地接受连接。有一些文档表明here 我相信推荐的访问方法是像现在一样将其锁定并通过主机名访问代理。

【讨论】:

    猜你喜欢
    • 2019-09-23
    • 2019-04-18
    • 1970-01-01
    • 2020-02-22
    • 2018-08-29
    • 2019-10-15
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多