I am experiencing compatibility issues between different versions of Kafka server and kafka-clients library.
kafka-client 0.8.2.2 to Kafka server 0.9.0.1 works fine, but when using kafka-client 0.9.0.1 to Kafka server 0.8.2.2 I get timeout when waiting for the future returned by Producer.send(). The message is properly sent without delay though. Code is here: https://github.com/apache/logging-log4j2/blob/master/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java Problem: java.util.concurrent.TimeoutException: Timeout after waiting for 30000 ms. at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:50) at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25) at org.apache.logging.log4j.core.appender.mom.kafka.KafkaManager.send(KafkaManager.java:81) -- [image: MagineTV] *Mikael Ståldal* Senior software developer *Magine TV* mikael.stal...@magine.com Grev Turegatan 3 | 114 46 Stockholm, Sweden | www.magine.com Privileged and/or Confidential Information may be contained in this message. If you are not the addressee indicated in this message (or responsible for delivery of the message to such a person), you may not copy or deliver this message to anyone. In such case, you should destroy this message and kindly notify the sender by reply email.
