The MirrorMaker 0.9.0 has some nice features like messageHandler which would be great to use.
Any ideas how this new functionality could be used in a 0.8.2 source cluster and 0.9.0 destination cluster in an efficient way? Thanks On Wed, Jan 6, 2016 at 11:30 AM, Ismael Juma <ism...@juma.me.uk> wrote: > 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! > > >
