Thanks, you are right, my consumer config was pointing to the 0.8! Cheers!
On 20 May 2014 05:36, Jun Rao <jun...@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.fir...@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. > > > > > > >
