hello,

i've got a set of broker nodes running 0.8.2.1. on my laptop i'm also running 0.8.2.1, and i have a single broker node and mirrormaker there. i'm also using kafka-console-consumer.sh on the mac to display messages on a favorite topic being published from the broker nodes. there are no messages on the topic, but everything is well-behaved. i can inject messages with kafkacat and everything is fine.

but then!

on the laptop i switched everything to 0.8.3 but left the broker nodes alone. now when i run mirrormaker i see this:

[2015-09-30 10:44:55,090] WARN [ConsumerFetcherThread-tivo_kafka_110339-mbpr.local-1443635093396-c55cbafb-0-5], Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@61cb11c5. Possible cause: java.nio.BufferUnderflowException (kafka.consumer.ConsumerFetcherThread) [2015-09-30 10:44:55,624] WARN [ConsumerFetcherThread-tivo_kafka_110339-mbpr.local-1443635093396-c55cbafb-0-5], Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@3c7bb986. Possible cause: java.nio.BufferUnderflowException (kafka.consumer.ConsumerFetcherThread) [2015-09-30 10:44:56,181] WARN [ConsumerFetcherThread-tivo_kafka_110339-mbpr.local-1443635093396-c55cbafb-0-5], Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@1d4fbd2c. Possible cause: java.nio.BufferUnderflowException (kafka.consumer.ConsumerFetcherThread) [2015-09-30 10:44:56,726] WARN [ConsumerFetcherThread-tivo_kafka_110339-mbpr.local-1443635093396-c55cbafb-0-5], Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@59e67b2f. Possible cause: java.nio.BufferUnderflowException (kafka.consumer.ConsumerFetcherThread)

if i use kafkacat to generate a message on the topic i see IllegalArgumentExceptions instead.

this suggests that the two versions of kafka aren't compatible. is this the case? does the whole ecosystem need to be on the same version?

thank you,
doug

Reply via email to