producteur de console Kafka ne manque pas si l'adresse courtier est incorrecte

Question

je lance la commande suivante (où <incorrect port> est un nombre):

bin/kafka-console-producer.sh --broker-list localhost:<incorrect port> --topic some-topic 

Et le processus ne marche pas l'échec, il continue comme si rien ne se trompe

Y at-il un moyen au démarrage de kafka-console-producer.sh pour vérifier le port du courtier de destination a un courtier à l'écoute de ce port au démarrage?

J'utilise kafka 0.10.2.0 sur osx 10.12.3

Answer 1

C'est par la conception ... Le producteur suppose juste que le courtier obtiendra disponible au port spécifié par la suite. Cependant, le producteur devrait expirer à un moment donné (l'IIRC par défaut est de 5 minutes). Vous pouvez réduire la configuration de timeout pour obtenir l'erreur plus tôt via request.timeout.ms ou metadata.fetch.timeout.ms.