Exception in thread "Thread-0" kafka.common.FailedToSendMessageException
来源:4-9 -Kafka Producer Java API编程

慕码人0236634
2018-04-13
1. 遇到报错
Exception in thread "Thread-0" kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:91)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.imooc.spark.kafka.KafkaProducer.run(KafkaProducer.java:157)
2. 而实际上,在服务器上通过下述命令可以实现正常消费
kafka-console-producer.sh --broker-list hadoop000:9092 --topic hello_topic
kafka-console-consumer.sh --zookeeper hadoop000:2181 --topic hello_topic --from-beginning
3. 自己尝试进行的处理:通过搜索引擎查找相关信息,提示可能与 server.property 的host和port有关,但是实际中已经按照教程进行了配置。
可否帮忙提供下解决思路?
5回答
-
chokingwin
2018-05-03
我也碰到这个问题。我是这么解决的。
前置说明:我的环境是:win10+vmware加载的OOTB镜像。
在Windows的hosts里面添加如下一行映射,就可以了。
192.168.xxx.xxx hadoop000
这个ip是虚拟机的ip
212020-08-14 -
LeoTomato23
2018-05-02
我也遇到了,原因在于你本地机器没有构建hadoop000相对应的映射关系,因为server当中都是用hadoop000代替ip地址的,所以不能发送。
20 -
白笔一文字
2018-04-17
我也遇到了相同的问题,然后尝试解决了下,问题出在config目录下的server.properties,listeners=PLAINTEXT://:9092,中间应该添加kafka服务器的ip地址,比如我的配置是: listeners=PLAINTEXT://10.10.1.1:9092,添加后即可解决。
20 -
慕码人0236634
提问者
2018-04-13
谢谢。我应该是没有修改server.property的,但是不知道会出问题。
022018-04-15 -
Michael_PK
2018-04-13
这个问题好像已经有好几个人遇到了,我上课的环境是没有其他地方有配置,如果你用了ootb的环境的话,你可以对比下对应的server.properties配置文件。这个问题你先按照那个解决了然后继续往下学先,我找时间来研究下这几个参数的问题,或者搜一下看看问答,我记得似乎有解决过类似的问题
00
相似问题