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

部署Flume在Window环境中,Kafka部署在Linux上,从Flume发送事件到Kafka始终有一下错误,

经过长时间在网上搜索终于把问题解决,

解决办法1:

修改kafka中配置项,

#advertised.host.name=<hostname routable by clients>

注释去掉,并配置上kafka所在linux的ip地址

advertised.host.name=192.168.10.10

重启kafka。

解决办法2(推荐):

将kafka所在linux的(ip,别名)配置到Window环境中hosts文件:

1
192.168.10.10  kafka.host

Flume配置文件consumer.properties中

1
producer.sinks.r.brokerList = kafka.host:9092

转载自:http://10120275.blog.51cto.com/10110275/1764526/

本站的文章多是老王开发工作中问题的记录,一个字一个字敲的,切实可行,可以分享,需要留个原文链接,至少也意思意思吧!
vsalw技术博客 » Failed to send producer request with correlation id 2 to broker 0 with

每个人都是以自己独特的方式体味生活,或许别人不理解,但自己知道:其中的酸甜苦辣就叫做幸福!

认同! 瞎扯淡!