卡夫卡汇合问题，同时产生消息

我已经开始使用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

卡夫卡汇合问题，同时产生消息

回答

相关问题