更新时间:2022-11-27 11:04:27
在你的 kafka server.properties
中有一个注释配置
#advertised.host.name=
取消注释并添加运行 kafka 的 Linux 机器的 IP.
advertised.host.name=
并从客户端连接到
这应该可以解决您的问题.
编辑
或者,您可以取消注释
#advertised.port=9092
此外,如果您正在侦听与默认端口不同的端口.
I'm trying to create a Kafka
cluster to send messages to a remote control. I have configured everything as described here.
I am running this on a Linux red hat
machine, and it works fine using the shell. After writing the java code as described in the quick start
tutorial on my windows machine, I have received the following error:
...
DEBUG kafka.client.ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(example)
...
ERROR kafka.producer.SyncProducer - Producer connection to cldExampleKafka.domain:80 unsuccessful
java.nio.channels.UnresolvedAddressException
...
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44)
...
WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 2 to broker 0 with data for patitions [ati,0]
java.nio.channels.UnresolvedAddressException
...
kafka.common.FailedToSendMessageException: Failed to send message after 3 tries.
I have also tried to run the jar in a different Linux machine, and still received the same error.
Changing the address to localhost
and running the java code as a jar in the machine where the kafka is installed works.
I believe it something with the configuration, but I couldn't find it.
In your kafka server.properties
there is a commented configuration
#advertised.host.name=<Some IP>
Uncomment this and add the IP of the Linux Machine in which kafka is running.
advertised.host.name=<Kafka Running Machine IP>
And connect from clients to <Kafka Running Machine IP>
This should fix your issue.
EDIT
Optionally you can uncomment the
#advertised.port=9092
Also if you are listening on a different port than the default one.