I tried running console consumer-producer from the localhost on the cluster:
this say me that the broker is currently active.

To reach the cluster from outside I use a redirect from a public (ip, port),
because the ip of the kafka broker is private... I suspect the problem can
be there.



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-during-Kafka-connection-tp14822p14828.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.

Reply via email to