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
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
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