Hi, I have setup a ssh tunnel for cross dc kafka replication using mirrormaker.
The following command succeeds: $ proxychains4 /opt/kafka/bin/kafka-console-producer.sh --broker-list 172.19.19.19:9092 --topic test But using the new producer throws an error without producing any message: $ proxychains4 /opt/kafka/bin/kafka-console-producer.sh --broker-list 172.19.19.19:9092 --topic test --new-producer [2015-12-09 15:32:56,452] ERROR Error when sending message to topic test with key: null, value: 1 bytes with error: Failed to update metadata after 60000 ms. (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) Someone kindly help me debug this. Is there a major change in how the new producer makes connections? Thanks, Siddhartha