卡夫卡匯合問題，同時產生消息

我已經開始使用SSL配置kafka服務器。當我運行kafka控制檯生產者時出現以下錯誤卡夫卡匯合問題，同時產生消息

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

我嘗試了相同的步驟，由您共享的鏈接被提及，但它並沒有幫助。我仍然面臨同樣的問題。 – shamim

您使用的是哪個版本的融合平臺，您在哪個平臺上運行，以及您的代理安裝在何處（本地或遠程？）在您的代碼示例中，我沒有看到ssl配置。另外，我不確定你的「發送信息」是什麼。你能發佈完整的代碼示例嗎？ – Treziac

我正在使用3.2。我已經安裝在本地。我用ssl配置細節更新了server.properties。像列表器和其他ssl細節。啓動kafka服務器後，我正在運行命令./kafka-console-producer --broker-list server：9094 --topic logs --property.config myproperties文件，我看到錯誤 – shamim

卡夫卡匯合問題，同時產生消息

回答

相關問題