kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mikael Ståldal <mikael.stal...@magine.com>
Subject Compatibility between different versions of Kafka server and kafka-clients library
Date Mon, 30 May 2016 16:29:37 GMT
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.staldal@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.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message