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經紀人服務器斷開

回答

相關問題