Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Kafka 0.7 Quickstart Errors


Copy link to this message
-
Re: Kafka 0.7 Quickstart Errors
Perfect Jun! It works. Thanks a ton.

On Mon, Jul 8, 2013 at 9:00 AM, Jun Rao <[EMAIL PROTECTED]> wrote:

> The following is the weird part. 0:0 is not a valid host and port. Could
> you take a look at the EC2 FAQ in
> https://cwiki.apache.org/confluence/display/KAFKA/FAQ? It's for the
> consumers, but may apply to the producers too.
>
> [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
>
> Thanks,
>
> Jun
>
>
> On Sat, Jul 6, 2013 at 3:30 PM, Yavar Husain <[EMAIL PROTECTED]>
> wrote:
>
> > 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 <[EMAIL PROTECTED]>
> > 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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]
> > >> >wrote:
> > >>
> > >> > Kafka 0.8 works great. I am able to use CLI as well as write my own
> > >> > producers/consumers!
> > >> >