問題連接到卡夫卡經紀人

Question

我想連接到使用春季卡夫卡客戶端的卡夫卡服務器&我在日誌中看到下面的錯誤。我連接到一個特定的kafka經紀人IP，我驗證了這一點。我似乎在下面的錯誤日誌中看到了本地引用。你能幫我進一步調試嗎？

我推送使用logback.xml。以下是配置。在測試之前我硬編碼了kafka主機和端口。相同的代碼和配置適用於其中一種環境。

<appender name="asyncVerboseKafka" 
    class="net.logstash.logback.appender.LoggingEventAsyncDisruptorAppender"> 
    <appender name="kafkaVerboseAppender" 
     class="com.github.danielwegener.logback.kafka.KafkaAppender"> 
     <encoder 
      class="com.github.danielwegener.logback.kafka.encoding.LayoutKafkaMessageEncoder"> 
      <layout class="ch.qos.logback.classic.PatternLayout"> 
       <pattern>verbose-${springActiveProfile}- %msg</pattern> 
      </layout> 
     </encoder> 
     <topic>${verbosetopic}</topic> 
     <keyingStrategy 
      class="com.github.danielwegener.logback.kafka.keying.RoundRobinKeyingStrategy" /> 
     <deliveryStrategy 
      class="com.github.danielwegener.logback.kafka.delivery.AsynchronousDeliveryStrategy" /> 
     <producerConfig>bootstrap.servers=${kafkaHostName}:${kafkaHostPort} 
     </producerConfig> 
     <producerConfig>retries=2</producerConfig> 
    </appender> 
</appender> 

2017-10-18T15：33：50.650-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017年10月18日 15：33：50.649 DEBUG - org.apache.kafka.clients.NetworkClient ：節點-1斷開連接。 2017-10-18T15：33：50.650-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.649 DEBUG - org .apache.kafka.clients.NetworkClient：放棄發送元數據 請求，因爲沒有節點可用2017-10-18T15：33：50.650-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.649 DEBUG - o.apache.kafka.common.network.Selector：連接 localhost/127.0.0.1斷開2017-10-18T15：33：50.750- 04:00 調試 - org.apache.kafka.clients.NetworkClient：Initialize [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.749連接到節點 -1用於發送元數據請求2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - org.apache.kafka.clients.NetworkClient：啓動到localhost：9092的節點 -1的連接。 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - org。 apache.kafka.clients.NetworkClient：初始化連接到節點 -1用於發送元數據請求2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - o.apache.kafka.common.network.Selector：連接 localhost/127.0.0.1斷開連接2017-10-18T15：33：50.750-04： 00 [APP/PROC/WEB/0] [OUT] at sun.nio.ch.SocketChannelImpl.checkConnect（Native Method） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] java.net.ConnectException：連接被拒絕 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at sun.nio.ch.SocketCh annelImpl.finishConnect（SocketChannelImpl.java:717） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.PlaintextTransportLayer。 finishConnect（PlaintextTransportLayer.java:54） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.NetworkClient.poll（NetworkClient。 java：270） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.KafkaChannel.finishConnect（KafkaChannel.java： 79） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.Selector.poll（Selector.java:274） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] java.lang.Thread.run（Thread.jav a：745）2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.producer.internals.Sender.run（Sender。 java：216） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15:33： 50.750 DEBUG - org.apache.kafka.clients.NetworkClient ：節點-1斷開連接。 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - org .apache.kafka.clients。NetworkClient：放棄發送元數據 請求，因爲沒有節點可用2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT]在 org.apache.kafka.clients.producer .internals.Sender.run（Sender.java:128） 2017-10-18T15：33：50.751-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - org.apache.kafka.clients.NetworkClient ：放棄發送元數據請求，因爲沒有節點可用 2017-10-18T15：33：50.851-04：00 [APP/（APP/PROC/WEB/0）[OUT] at org.apache.kafka.common.network.KafkaChannel.finishConnect（KafkaChannel.java:79） 2017-10-18T15：33：50.851-04：00 [ WEB/0] [OUT] org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:128） 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] java.lang.Thread.run（Thread.java:745）2017-10-18T15：33： 50.851-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.851 DEBUG - o.apache.kafka.common.network .Selector：連接 localhost/127.0.0.1已斷開2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT]在 org.apache.kafka.common.network。 Selector.poll（Selector.java:274） 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 012-2017-10 -18 15：33：50.850 DEBUG - org.apache.kafka.clients.NetworkClient ：在本地主機：9092上啓動與節點-1的連接。 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] at sun.nio.ch.SocketChannelImpl.finishConnect（SocketChannelImpl.java:717） 2017-10-18T15 ：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:216） 2017-10-18T15 ：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.851 DEBUG - org.apache.kafka.clients .NetworkClient ：節點-1斷開連接。 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.851 DEBUG - org .apache.kafka.clients.NetworkClient：放棄發送元數據 請求，因爲沒有節點可用2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.850調試 - org.apache.kafka.clients.NetworkClient：初始化連接到節點 -1用於發送元數據請求2017-10-18T15：33：50.851- 04:00 [APP/PROC/WEB/0] [OUT] org.apache.kafka.clients.NetworkClient.poll（NetworkClient.java:270） 2017-10-18T15：33：50.851-04：00 [ APP/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect（PlaintextTransportLayer.java:54） 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] java.net.ConnectException：拒絕連接 2017-10-18T15：33：50.851-04： [APP/PROC/WEB/0] [OUT] at sun.nio.ch.SocketChannelImpl.checkConnect（Native Method） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [ OUT] [] [] [] [] [] 2017-10-18 15：33：50.952調試 - o.apache.kafka.common.network.Selector ：與localhost/127.0.0.1斷開連接 2017-10 -18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.KafkaChannel.finishConnect（KafkaChannel.java:79） 2017-10-18T15 ：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:216） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:128）在線等待時間：2017年03月18日 - 2017年10月17日星期四33:50.952-04：00 [APP/PROC/WEB/0] [OUT] java.lang.Thread.run（Thread.java:745）2017-10-18T15： 50。952-04：00 [APP/PROC/WEB/0] [OUT] sun.nio.ch.SocketChannelImpl.checkConnect（Native Method） 2017-10-18T15：33：50.952-04：00 [APP/（APP/PROC/WEB/0）[0128] [0160] [OUT] at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect（PlaintextTransportLayer.java:54） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] ] at org.apache.kafka.clients.NetworkClient.poll（NetworkClient.java:270） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] [] [ ] [] [] [] 2017-10-18 15：33：50.951 DEBUG - org.apache.kafka.clients.NetworkClient ：Init在localhost：9092處連接到節點-1。 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] java.net.ConnectException：連接被拒絕

Answer 1

發起連接到節點-1在本地主機：9092。 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] java.net.ConnectException：拒絕連接

表示主機/端口不正確;它試圖在本地機器上連接到Kafka。

您需要顯示如何在屬性中配置引導程序服務器。