Hi ,

I am trying to run MirrorMaker from 0.9broker as source and 0.8.2.1 broker as 
destination.

MirrorMaker is run from source(I.e. Using 0.9’s code)

I am getting the following error message after it sends out first message.


ERROR Uncaught error in kafka producer I/O thread:  
(org.apache.kafka.clients.producer.internals.Sender)

org.apache.kafka.common.protocol.types.SchemaException: Error reading field 
'throttle_time_ms': java.nio.BufferUnderflowException

at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)

at 
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:464)

at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:279)

at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:216)

at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:128)

at java.lang.Thread.run(Thread.java:745)


Why does this issue arise, since Kafka 0.9 producer client is compatible with 
0.8.2.1 broker?


Thanks,

Tushar

Reply via email to