Hi Jun I am still not able to run Kafka 0.7. and getting the same error as described in my thread. As for Kafka Spout to work I need Kafka 0.7 so it would be great if you could help me out with this. I did not understand what you mentioned in your last message "wipe out both Zookeeper and Kafka 0.8 data".I just changed the log data directories in both kafka and zookeeper configs and still I am getting the same error. Isn't that sufficient? What else do I need to do to wipe out the data? What directories do I need to visit?
Will the above be the reason for getting the following error: [2013-06-28 14:06:05,606] INFO Creating async producer for broker id = > > 0 at 0:0 (kafka.producer.ProducerPool) > > 5) Time to send some messages & oops I get this error: > > [2013-06-28 14:07:19,650] INFO Disconnecting from 0:0 > > (kafka.producer.SyncProducer) > > [2013-06-28 14:07:19,653] ERROR Connection attempt to 0:0 failed, next > > attempt in 1 ms (kafka.producer.SyncProducer) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.Net.connect0(Native Method) > > at sun.nio.ch.Net.connect(Net.java:364) > > at sun.nio.ch.Net.connect(Net.java:356) > > at > sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:623) > > at kafka.producer.SyncProducer.connect(SyncProducer.scala:173) > > at > > kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:196) > > at kafka.producer.SyncProducer.send(SyncProducer.scala:92) > > at kafka.producer.SyncProducer.multiSend(SyncProducer.scala:135) > > at > > > kafka.producer.async.DefaultEventHandler.send(DefaultEventHandler.scala:58) > > at > > > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:44) > > at > > > kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:116) > > at scala.collection.immutable.Stream.foreach(Stream.scala:254) > > at > > > kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:70) > > at > > kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:41) Regards, Yavar On Thu, Jul 4, 2013 at 4:53 PM, Yavar Husain <yavarhus...@gmail.com> wrote: > Hey Jun > > Thanks for your prompt response. I don't really get "wipe out both > Zookeeper and Kafka 0.8 data". I just changed the log data directories in > both kafka and zookeeper configs and still I am getting the same error. > Isn't that sufficient? What else do I need to do to wipe out the data? What > directories do I need to visit? > > Thanks, > Yavar > > > On Mon, Jul 1, 2013 at 9:13 PM, Jun Rao <jun...@gmail.com> wrote: > >> You need to wipe out both the ZK data and the Kafka data from 0.8, in >> order >> to try 0.7. >> >> Thanks, >> >> Jun >> >> >> On Sun, Jun 30, 2013 at 11:28 PM, Yavar Husain <yavarhus...@gmail.com >> >wrote: >> >> > Kafka 0.8 works great. I am able to use CLI as well as write my own >> > producers/consumers! >> > >> > Checking Zookeeper... and I see all the topics and partitions created >> > successfully for 0.8. >> > >> > Kafka 0.7 does not work! >> > >> > Why Kafka 0.7? I am using Kafka Spout from Storm which is made for Kafka >> > 0.7. >> > >> > First I just want to run CLI based producer/consumer for Kafka 0.7, >> which I >> > am unable to. I carry out the following steps: >> > >> > 1) I delete all the topics/partitions etc. in Zookeeper that were >> > created from my Kafka 0.8 >> > 2) I change the dataDir in zoo.cfg to point to different location. >> > 3) Now I start the kafka server 0.7. It starts successfully. However >> > I don’t know why it again registers the broker topics I deleted? >> > 4) Now I start the Kafka Producer : >> > bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic >> topicime >> > & it starts successfully: >> > [2013-06-28 14:06:05,521] INFO zookeeper state changed (SyncConnected) >> > (org.I0Itec.zkclient.ZkClient) >> > [2013-06-28 14:06:05,606] INFO Creating async producer for broker id = >> > 0 at 0:0 (kafka.producer.ProducerPool) >> > 5) Time to send some messages & oops I get this error: >> > [2013-06-28 14:07:19,650] INFO Disconnecting from 0:0 >> > (kafka.producer.SyncProducer) >> > [2013-06-28 14:07:19,653] ERROR Connection attempt to 0:0 failed, next >> > attempt in 1 ms (kafka.producer.SyncProducer) >> > java.net.ConnectException: Connection refused >> > at sun.nio.ch.Net.connect0(Native Method) >> > at sun.nio.ch.Net.connect(Net.java:364) >> > at sun.nio.ch.Net.connect(Net.java:356) >> > at >> sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:623) >> > at kafka.producer.SyncProducer.connect(SyncProducer.scala:173) >> > at >> > kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:196) >> > at kafka.producer.SyncProducer.send(SyncProducer.scala:92) >> > at kafka.producer.SyncProducer.multiSend(SyncProducer.scala:135) >> > at >> > >> kafka.producer.async.DefaultEventHandler.send(DefaultEventHandler.scala:58) >> > at >> > >> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:44) >> > at >> > >> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:116) >> > at scala.collection.immutable.Stream.foreach(Stream.scala:254) >> > at >> > >> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:70) >> > at >> > kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:41) >> > >> > Note that Zookeeper is already running. >> > >> > Any help would really be appreciated. >> > >> > *EDIT:* >> > >> > I don't even see the topic being created in zookeeper. I am running the >> > following command: >> > >> > bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic >> topicime >> > >> > After the command everything is fine & I get the following message: >> > >> > [2013-06-28 14:30:17,614] INFO Session establishment complete on >> > server localhost/127.0.0.1:2181, sessionid = 0x13f805c6673004b, >> > negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) >> > [2013-06-28 14:30:17,615] INFO zookeeper state changed (SyncConnected) >> > (org.I0Itec.zkclient.ZkClient) >> > [2013-06-28 14:30:17,700] INFO Creating async producer for broker id = >> > 0 at 0:0 (kafka.producer.ProducerPool) >> > >> > However now when i type a string to send I get the above error >> (Connection >> > refused!) >> > >> > >
