Hi Stephen, Newer brokers support older clients, but not the other way around. You could try 0.8.2 MirrorMaker against 0.8.2 source and 0.9.0 target clusters perhaps?
Ismael On 6 Jan 2016 11:18, "Stephen Powis" <spo...@salesforce.com> wrote: > Hey! > > So I'm trying to get mirror maker going between two different clusters. My > source cluster is version 0.8.2 and my destination cluster is 0.9.0 running > the mirror maker code from the 0.9.0 release. Does anyone know if this is > possible to do? I'm aware that the protocol changed slightly between > versions. > > Attempting to run ./kafka-console-consumer.sh from the 0.9.0 release and > consume from my 0.8.2 cluster seems to fail, which is leading me to believe > that mirror maker will have the same issue. > > Attached is the errors I receive from kafka-console-consumer.sh running > from 0.9.0 release against a 0.8.2 cluster. > > ./kafka-console-consumer.sh --zookeeper W.X.Y.Z:2181 --topic MyTopic > > [2016-01-06 06:17:40,587] WARN > > [ConsumerFetcherThread-console-consumer-73608_hostname-1452079050696-728e3f7e-0-100], > Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@6bb31fae. > Possible cause: java.lang.IllegalArgumentException > (kafka.consumer.ConsumerFetcherThread) > ... > > Thanks! >
