Kafka Brokerに接続する際の問題

Spring Kafkaクライアントを使用してKafkaサーバーに接続しようとしています&ログに以下のエラーが表示されます。私は特定のkafkaブローカーIPに接続しています。私は以下のエラーログにローカル参照が表示されているようです。これをさらにデバッグするのを手伝ってください。Kafka Brokerに接続する際の問題

私はlogback.xmlを使用してプッシュしています。以下はその構成です。私はテストの前にカフカホストとポートをハードコードしました。同じコードと構成は、いずれかの環境で動作します。

<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 disconnected 2017-10-18T15：33：50.750- [APP/PROC/WEB/0] [OUT] [] [] [] [] 2017-10-18 15：33：50.749 DEBUG - org.apache.kafka.clients.NetworkClient：Initializeノードへの接続 -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への接続をlocalhost：9092で開始します。 2017-10-18T15：33：50.750-04：00 [APP]/[PROC/WEB/0] [OUT] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG - org。 [APP/PROC/WEB/0] [OUT] [] [] [] [] [] [] [] 2017-10-18 15：33：50.750 DEBUG- o.apache.kafka.common.network.Selector：との接続localhost/127.0.0.1 disconnected 2017-10-18T15：33：50.750-04： 00 の[APP]/PROC/WEB/0] [OUT]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 [APP/PROC/WEB/0] [OUT] org.apache.kafka.common.network.PlaintextTransportLayerでannelImpl.finishConnect（SocketChannelImpl.java:717） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] のorg.apache.kafka.clients.NetworkClient.poll（NetworkClient.paファイル）で、finishConnect（PlaintextTransportLayer.java:54） 2017-10-18T15：33：50.750-04：00 java/270： 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] 7935）の[APP/PROC/WEB/0] [OUT] 2017-10-18T15：33：50.750-04：00 org.apache.kafka.common.network.Selector.poll（Selector.java:274） 2017-10-18T15：33：50.750-04：00 [APP/PROC/WEB/0] [OUT] at 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。 [APP/PROC/WEB/0] 2017-10-18T15：33：50.750-04：00 [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/PROC/WEB/0] [OUT] at org.apache.kafka.common.network.KafkaChannel.finishConnect（KafkaChannel.java:79） 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] at org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:128） 2017-10-18T15：33：50.851-04：の[APP]/[PROC/WEB/0] 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] [] [] [] [] 2017-10 -18 15：33：50.850 DEBUG - org.apache.kafka.clients.NetworkClient ：ローカルホストでノード-1への接続を開始しています：9092。 2017-10-18T15：33：50.851-04：00 [APP/PROC/WEB/0] [OUT] 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 DEBUG - 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] sun.nio.ch.SocketChannelImpl.checkConnect（ネイティブメソッド） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] [OUT] [] [] [] [] [] 2017-10-18 15：33：50.952 DEBUG - 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] org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:128）の2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [OUT] java.lang.Thread.run（Thread.java:745）2017-10-18T15：33： 2017-10-18T15： 50。[APP/PROC/WEB/0] [OUT] at sun.nio.ch.SocketChannelImpl.checkConnect（ネイティブメソッド） 2017-10-18T15：33：50.952-04：00 [APP/PROC] PROC/WEB/0] [OUT] sun.nio.ch.SocketChannelImpl.finishConnect（SocketChannelImpl.java:717） 2017-10-18T15：33：50.952-04：00 [APP/PROC/WEB/0] [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 ] 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：接続ノードへの接続を開始

出典

2017-10-18 Punter Vicky

を拒否-1でlocalhost：9092。 2017-10-18T15：33：50.952から04：00 [APP/PROC/WEB/0] [OUT] java.net.ConnectException：接続が

を拒否したホスト/ポートが不正であることを意味します。あなたのローカルマシンのKafkaに接続しようとしています。

プロパティでブートストラップサーバーをどのように構成したかを示す必要があります。

出典

2017-10-18 19:59:18

ありがとうございました。私は設定情報を更新しました。 kafkaホストとポートを設定ファイルにハードコーディングしました。 –

これはSpringと何が関係がありますか？それはログバック設定です。 –

申し訳ありませんが、私は春のカフカを使った消費者を書いています。私はここで混ざり合った。私はそれを削除されます。 –

Kafka Brokerに接続する際の問題

答えて

関連する問題