Re: Kafka Migration Tool

2014-05-21 Thread Mo Firouz
Thanks, you are right, my consumer config was pointing to the 0.8! Cheers! On 20 May 2014 05:36, Jun Rao wrote: > It seems that you may have set the zk connection string to one used by 0.8 > Kafka brokers. > > Thanks, > > Jun > > > On Mon, May 19, 2014 at 8:34 AM, Mo Firouz > wrote: > > > Hi a

Re: Kafka Migration Tool

2014-05-19 Thread Jun Rao
It seems that you may have set the zk connection string to one used by 0.8 Kafka brokers. Thanks, Jun On Mon, May 19, 2014 at 8:34 AM, Mo Firouz wrote: > Hi all, > > I'm trying to migrate from Kafka 0.7.2-2.9.2 (with Zookeeper 3.3.4 from > Cloudera) to Kafka 0.8.1.1-2.9.2 (with official Zooke

Kafka Migration Tool

2014-05-19 Thread Mo Firouz
Hi all, I'm trying to migrate from Kafka 0.7.2-2.9.2 (with Zookeeper 3.3.4 from Cloudera) to Kafka 0.8.1.1-2.9.2 (with official Zookeeper 3.4.5 ) - However hitting brick walls with a very mysterious problem: 6) at kafka.tools.KafkaMigrationTool.main(KafkaMigrationTool.java:217) Caused by: java.la