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!
