カフカメッセージの作成中に合併問題

私はkafkaサーバーをSSL構成で開始しました。私はkafka-console-producerを実行するとエラーになります。カフカメッセージの作成中に合併問題

sending message... 
Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms. 
    at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:730) 
    at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:483) 
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430) 
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:353) 
    at ProducerClass.main(ProducerClass.java:44) 
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms. 


./kafka-console-producer --broker-list server:9094 --topic logs                              
j 
[2017-08-08 22:29:59,399] ERROR Error when sending message to topic logs with key: null, value: 1 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) 
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

出典

2017-08-09 shamim

sslを使用するようにクライアントを設定する必要があります。

http://docs.confluent.io/current/kafka/ssl.html

https://kafka.apache.org/documentation/#security_ssl

出典

2017-08-09 07:36:29 Treziac

あなたが共有するリンクで述べたように、私は同じ手順を試してみましたが、それは助けにはならなかった。ここでは、2つの便利リンクがあります。私はまだ同じ問題に直面しています。 – shamim

コンフルエントプラットフォームのどのバージョンを使用していますか、どのプラットフォームで実行するか、ブローカはどこにインストールされていますか（ローカルまたはリモート）サンプルコードでは、ssl設定は表示されません。また、私はあなたの "メッセージを送る"が何であるか分かりません。完全なコードサンプルを投稿できますか？ – Treziac

私は3.2を使用しています。私は地元に設置した。私はsslの設定の詳細でserver.propertiesを更新しました。リスナーと他のSSLの詳細のような。 kafkaサーバーを起動した後、私はコマンドを実行しています./kafka-console-producer --broker-list server：9094 --topic logs --property.config mypropertiesファイルと私はそのエラーを表示しています – shamim

カフカメッセージの作成中に合併問題

答えて

関連する問題