You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Mo Firouz <Mo...@visualdna.com> on 2014/05/19 17:34:52 UTC

Kafka Migration Tool

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.lang.NumberFormatException: For input string:
""1400511498394","host""

I've attached logs, scripts and configs from everything that I'm trying to
run.

FYI: We have three servers for Kafka Brokers and three servers for
Zookeeper. They are running on Staging (stag) as number s04, s05 and s06.
I've only given the properties for s04 as the other two are almost
identical.

Thanks,
Cheers,
Mo.

Re: Kafka Migration Tool

Posted by Mo Firouz <Mo...@visualdna.com>.

Thanks, you are right, my consumer config was pointing to the 0.8! Cheers!


On 20 May 2014 05:36, Jun Rao <ju...@gmail.com> 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 <Mo...@visualdna.com>
> 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 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.lang.NumberFormatException: For input string:
> > ""1400511498394","host""
> >
> > I've attached logs, scripts and configs from everything that I'm trying
> to
> > run.
> >
> > FYI: We have three servers for Kafka Brokers and three servers for
> > Zookeeper. They are running on Staging (stag) as number s04, s05 and s06.
> > I've only given the properties for s04 as the other two are almost
> > identical.
> >
> > Thanks,
> > Cheers,
> > Mo.
> >
> >
> >
>

Re: Kafka Migration Tool

Posted by Jun Rao <ju...@gmail.com>.

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 <Mo...@visualdna.com> 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 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.lang.NumberFormatException: For input string:
> ""1400511498394","host""
>
> I've attached logs, scripts and configs from everything that I'm trying to
> run.
>
> FYI: We have three servers for Kafka Brokers and three servers for
> Zookeeper. They are running on Staging (stag) as number s04, s05 and s06.
> I've only given the properties for s04 as the other two are almost
> identical.
>
> Thanks,
> Cheers,
> Mo.
>
>
>