【问题标题】:kafka message sent from one machine to another从一台机器发送到另一台机器的kafka消息
【发布时间】:2021-06-25 21:39:06
【问题描述】:

我已经开始这个教程https://kafka.apache.org/quickstart,在本地主机的情况下它工作正常

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

但是当我想在另一台机器上发送文本时 bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server 10.22.241.59:9092

这给了我以下错误

WARN [Producer clientId=console-producer] Error connecting to node test-3-workernode:9092 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)

如何发送消息给其他机器?为什么连接不上?

【问题讨论】:

  • don't upload text as image。编辑您的问题以包含所有信息。但是该错误消息的哪一部分不清楚?
  • @OlafKock bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server 10.22.241.59:9092 这个命令给了我错误。我的意思是当我写一些东西要发送时,它会给我错误。它没有与另一台机器连接
  • 你能分享任何 kafka 属性/配置吗? Kafka 引导服务器进程是否已在该机器上启动/安装?
  • 是的,我已经按照教程 bin/zookeeper-server-start.sh config/zookeeper.properties 和 bin/kafka-server-start.sh config/server.properties 都运行然后运行命令 bin/ kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092 并写下当我检查 bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning 时出现的内容- -bootstrap-server localhost:9092
  • @suraj_fale 但我想从这台机器向另一台机器发送文本,而不是本地主机,当我使用另一个 IP 时,它给了我错误

标签: apache-kafka


【解决方案1】:

您需要配置代理,以便它告诉客户端连接到它的位置。这是使用advertised.listeners 设置完成的。没有它,代理看起来就像默认为机器的主机名,您的客户端无法解析。 虽然您的客户端使用您为 initial 连接指定的 IP 地址,但它使用 broker 为后续连接提供的主机详细信息。

您可以在此处了解更多信息:https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/

【讨论】:

  • 好的,如果我还有其他问题,我会尽力回复您
猜你喜欢
  • 1970-01-01
  • 2019-05-19
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2011-04-23
  • 2016-03-23
  • 2013-11-29
相关资源
最近更新 更多