我已经在ec2示例上部署了kafka集群,ip a.b.c.d
和dns名称 XYZ_KAFKA
生产者也部署在另一个具有ip的ec2示例上 a2.b2.c2.d2
,要连接到kafka服务器,生产者使用dns名称 XYZ_KAFKA
在producer日志文件上,它总是在尝试生成时给出一个错误
24 Oct 2017 07:01:35,384 INFO ProducerSendThread- kafka.producer.SyncProducer - Connected to XYZ_KAFKA:9092 for producing
24 Oct 2017 07:01:35,387 INFO ProducerSendThread- kafka.producer.SyncProducer - Disconnecting from XYZ_KAFKA:9092
codeVal 22
num of partitions 0
24 Oct 2017 07:01:35,388 ERROR ProducerSendThread- kafka.producer.SyncProducer - Producer connection to ip-a-b-c-d:9092 unsuccessful
java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:107)
我更新了 advertised.host.name=XYZ_KAFKA
,但仍有相同的错误。我很困惑为什么制作人不能解析Kafka域名
还有一点,我检查了producer ec2示例是否可以看到kafka ec2示例
nc -zv XYZ_KAFKA 9092
Connection to XYZ_KAFKA 9092 port [tcp/XmlIpcRegSvc] succeeded!
暂无答案!
目前还没有任何答案,快来回答吧!