apache kafka生产者NetworkClient经纪人服务器断开

我在apache kafka新手上，我有关于连接到apache kafka.When的问题当我运行配置与基于java的aka kafka生产者其工作，但是当我添加打包的jar文件并运行阿帕奇的metron卡夫卡经纪人，如图下面apache kafka生产者NetworkClient经纪人服务器断开

2017-03-17 07:32:32 WARN NetworkClient:568 - Bootstrap broker node1:6667 disconnected

配置

bootstrap.servers=node1:6667 
acks=all 
retries=0 
batch.size=16384 
linger.ms=1 
buffer.memory=33554432 
key.serializer=org.apache.kafka.common.serialization.StringSerializer 
value.serializer=org.apache.kafka.common.serialization.StringSerializer

代码错误occure：

sender.send(new ProducerRecord<S, String>(getSenderTopic(), (S) getSenderKey(), 
      data), new Callback() { 
      public void onCompletion(RecordMetadata metadata, Exception e) { 
       if (e != null) { 
       LOGGER.error("exception ", e); 
       sender.close(); 
       } 
      } 
      });

阿帕奇kafka经纪人在阿帕奇metron和配置主机上运行node1：6667

我认为它的网络端问题，但你对它的建议是什么？谢谢

来源

2017-03-17 mithat konuk

所以经过研究，我已经解决了这个问题，关于kafka版本的问题apache metron使用10.0.1，我们使用10.1.0，在pom xml问题上改变了解决方案。

来源

2017-03-17 11:11:20

apache kafka生产者NetworkClient经纪人服务器断开

回答

相关问题