Re: java.nio.channels.ClosedChannelException in console-consumer.sh

2016-09-16 Thread Ali Akhtar
ion id 1 for topics > [Set(test)] from broker [BrokerEndPoint(1,kafka1-1876849043-91zso,9092)] > failed (kafka.client.ClientUtils$) > java.nio.channels.ClosedChannelException > at kafka.network.BlockingChannel.send(BlockingChannel.scala:110) > at kafka.producer.SyncProducer.liftedTree1$

java.nio.channels.ClosedChannelException in console-consumer.sh

2016-09-16 Thread Ali Akhtar
c metadata with correlation id 1 for topics [Set(test)] from broker [BrokerEndPoint(1,kafka1-1876849043-91zso,9092)] failed (kafka.client.ClientUtils$) java.nio.channels.ClosedChannelException at kafka.network.BlockingChannel.send(BlockingChannel.scala:110) at kafka.producer.SyncProduce

java.nio.channels.ClosedChannelException

2016-03-04 Thread Shivpriya Tamboskar
kafka.consumer.SimpleConsumer: Reconnect due to socket error: java.nio.channels.ClosedChannelException and consumer stops ... has anyone faced this problem before ? Thanks Shivpriya

Re: java.nio.channels.ClosedChannelException

2015-02-24 Thread Su She
exe...@yahoo.com.invalid> wrote: > Hi, I am learning kafka, ... hard way > I try to run the example given here: > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > Whatever I do i I have > java.nio.channels.ClosedChannelException when try to send message > E

java.nio.channels.ClosedChannelException

2015-02-24 Thread alexey yakubovich
Hi,  I am learning kafka, ... hard way I try to run the example given here:  https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example Whatever I do i I have  java.nio.channels.ClosedChannelException when try to send message Exception in thread "

java.nio.channels.ClosedChannelException

2015-01-30 Thread Sa Li
) java.nio.channels.ClosedChannelException at kafka.network.BlockingChannel.send(BlockingChannel.scala:100) at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73) at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72) at

Re: java.nio.channels.ClosedChannelException...Firewall Issue?

2015-01-19 Thread Su She
ist public.ip.of.A:9092 and topic test. >> >> 5) Once I start publishing messages this is the message I get (what's >> worse >> is that I can't cntrl C to stop and have to exit putty): >> >> WARN Fetching topic metadata with correlat

Re: java.nio.channels.ClosedChannelException...Firewall Issue?

2015-01-19 Thread Jaikiran Pai
.183.40.224,port:9092] failed (kafka.client.ClientUtils$) java.nio.channels.ClosedChannelException at kafka.network.BlockingChannel.send(BlockingChannel.scala:97) at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:74) at kafka.producer.SyncProducer.ka

java.nio.channels.ClosedChannelException...Firewall Issue?

2015-01-19 Thread Su She
er [id:0,host:54.183.40.224,port:9092] failed (kafka.client.ClientUtils$) java.nio.channels.ClosedChannelException at kafka.network.BlockingChannel.send(BlockingChannel.scala:97) at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:74) at kafka.producer.Syn