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.