kafka的producer报错异常
2016-07-04 15:51
288 查看
kafka的producer出现异常，现象如下
Exception in thread “Thread-0” kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.settlement.KafkaProducer.run(KafkaProducer.java:24)
出现问题原因是本地访问的远程kafka服务器默认是通过localhost的，需要转换配置下才可以，解决办法是打开service.properties
修改host.name为本机IP
Exception in thread “Thread-0” kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.settlement.KafkaProducer.run(KafkaProducer.java:24)
出现问题原因是本地访问的远程kafka服务器默认是通过localhost的，需要转换配置下才可以，解决办法是打开service.properties
修改host.name为本机IP
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- Kafka 之 中级
- Linux下Kafka单机安装配置方法(图文)
- Kafka使用入门教程第1/2页
- Logstash 与Elasticsearch整合使用示例
- 大数据实验室（大数据基础培训）——Kafka的安装、配置及基础使用
- 大数据实验室（大数据基础培训）——概要
- kafka-manager 的编译和使用（附安装包）
- Kafka+Log4j实现日志集中管理
- Kafka深度解析
- Kafka设计解析（三）- Kafka High Availability （下）
- kafka+storm初探
- storm集群 + kafka单机性能测试
- flume、kafka、storm常用命令
- kafka入门：简介、使用场景、设计原理、主要配置及集群搭建
- kafka集群的安装
- kafka 一些基本知识
- kafka0.10.0单机测试
- kafka 基本原理二
- Kafka入门经典教程