kafka Failed to send messages after 3 tries.

我在网上搜了很多资料

说是zookeeper的问题，修改更改server.properties下的host.name,zookeeper.connect的localhost 为ip地址

怎么也不管用

后来就单独建了一个项目，发现没有问题。结论是jar包冲突，逐个删除jar包发现是log4j的版本太低，需要1.2.12以上的版本

最后问题解决

总结：

一、其实这个问题可以早点解决，但是由于我没有仔细看日志，所有卡了我两天的时间。之前都是只看错误日志，不看警告日志

log4j:WARN No appenders could be found for logger (kafka.utils.VerifiableProperties).

log4j:WARN Please initialize the log4j system properly.

SLF4J: This version of SLF4J requires log4j version 1.2.12 or later. See also http://www.slf4j.org/codes.html#log4j_version

Exception in thread "main" kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

第二、公共jar包尽量使用高版本的东西。

第三、kafka 要是用ip,localhost 可能没数据

时间： 2025-01-17 06:18:32

kafka Failed to send messages after 3 tries.的相关文章

开发环境解决 kafka Failed to send messages after 3 tries

新建了一个kafka集群,在window下写了一个简单的producer做测试,结果遇到了消息发送失败的问题,代码如下: Properties props = new Properties(); props.put("metadata.broker.list", "192.168.1.107:6667"); props.put("serializer.class", "kafka.serializer.StringEncoder&quo

Failed to send producer request with correlation id 2 to broker 0 with

部署Flume在Window环境中,Kafka部署在Linux上,从Flume发送事件到Kafka始终有一下错误, 经过长时间在网上搜索终于把问题解决, 修改kafka中配置项, #advertised.host.name=<hostname routable by clients> 注释去掉,并配置上kafka所在linux的ip地址 advertised.host.name=192.168.10.10 重启kafka. 2016-04-16 16:43:34,069 (SinkRunner

etcd报错failed to send out heartbeat on time

etcd服务出现了以下报错Mar 23 05:50:44 localhost etcd: failed to send out heartbeat on time (exceeded the 100ms timeout for 2.951502ms) 心跳检测报错主要与以下因素有关(磁盘速度.cpu性能和网络不稳定问题): 第一,etcd使用了raft算法,leader会定时地给每个follower发送心跳,如果leader连续两个心跳时间没有给follower发送心跳,etcd会打印这个log

【Flume】Rpc sink XX closing Rpc client:NettyAvroRpcClient {xx} …… Failed to send events 问题解决

从以上截图信息,就可以看出问题了,服务端和客户端连接信息对不上,服务端有很多ESTABLISHED的连接,其实是无用的.这种情况,起初,我也很奇怪,没有发现原因,只能查看日志了. 通过日志信息,发现出现了异常,但是很奇怪,在异常信息之前,有一句Rpc sink {} closing Rpc client: {} 这里destroyConnection了,摧毁了一个连接,好端端的为什么会摧毁连接呢,从flume源码来看,flume自身不会出现这种低端的BUG吧,好端端,摧毁自己的连接干啥,所以从f

kafka无法发送消息问题处理

背景在服务器上搭建了一个单机环境的kafka broker,在服务器上使用命令生产消息时,一切正常.当在本地使用JAVA程序发送消息时,一直出错. 抛出的错误为: Exception in thread "main" Failed to send requests for topics test with correlation ids in [0,12] kafka.common.FailedToSendMessageException: Failed to send messag

kafka环境搭建二---Windows客户端Linux服务器

一.对于服务器端的搭建可以参考上一篇文章:kafka单机版环境搭建与测试服务器端IP :10.0.30.221 运行环境的目录如下: 需要改动config文件夹下的server.properties中的以下两个属性 zookeeper.connect=localhost:2181改成zookeeper.connect=10.0.30.221:2181 以及默认注释掉的 #host.name=localhost改成host.name=10.0.30.221 host.name不更改会造成客户端报

apache kafka系列之Producer处理逻辑

最近研究producer的负载均衡策略,,,,我在librdkafka里边用代码实现了partition 值的轮询方法,,,但是在现场验证时,他的负载均衡不起作用,,,所以来找找原因: 下文是一篇描写kafka处理逻辑的文章,转载过来,研究一下. apache kafka系列之Producer处理逻辑标签: Kafka ProducerKafka Producer处理逻辑kafka生产者处理逻辑apache kafka系列 2014-05-23 11:42 3434人阅读评论(2) 收藏举

kafka单节点部署无法访问问题解决

场景:在笔记本安装了一台虚拟机, 在本地的虚拟机上部署了一个kafka服务: 写了一个测试程序,在笔记本上运行测试程序,访问虚拟机上的kafka,报如下异常: 2015-01-15 09:33:26 [kafka.producer.async.DefaultEventHandler]-[INFO] Back off for 100 ms before retrying send. Remaining retries = 1 2015-01-15 09:33:26 [kafka.client.Cl

实践部署与使用apache kafka框架技术博文资料汇总

前一篇Kafka框架设计来自英文原文(Kafka Architecture Design)的翻译及整理文章,很有借鉴性,本文是从一个企业使用Kafka框架的角度来记录及整理的Kafka框架的技术资料,也很有借鉴价值,为了便于阅读与分享,我将其整理一篇Blog.本文内容目录摘要如下: 1)apache kafka消息服务 2)kafka在zookeeper中存储结构 3)kafka log4j配置 4)kafka replication设计机制 5)apache kafka监控系列-监控指标 6)