0
J'ai démarré le serveur kafka avec la configuration SSL. Je reçois ci-dessous erreur lorsque je lance le kafka-console-producteurKafka Problème confluent lors de la production du message
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.
I Tried les mêmes étapes que mentionné dans le lien partagé par vous, mais cela n'a pas aidé. Je suis toujours confronté au même problème. – shamim
Quelle version de la plate-forme confluente utilisez-vous, sur quelle plate-forme exécutez-vous et où votre courtier est-il installé (local ou distant?) Dans votre exemple de code, je ne vois pas de configuration ssl. En outre, je ne suis pas sûr de ce que votre "message d'envoi" est. Pouvez-vous poster un exemple de code complet? – Treziac
J'utilise 3.2. J'ai installé en local. J'ai mis à jour server.properties avec les détails de configuration ssl. comme les listes et autres détails SSL. après avoir démarré le serveur kafka, je cours la commande ./kafka-console-producer --broker-list server: 9094 --les logs de topic --property.config myproperties file et je vois cette erreur – shamim