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

2016-09-16 Thread Ali Akhtar
lation 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.liftedTre

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

2016-09-16 Thread Ali Akhtar
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.SyncProducer.liftedTree1$1

java.nio.channels.ClosedChannelException

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

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 main

Re: java.nio.channels.ClosedChannelException

2015-02-24 Thread Su She
...@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 Exception in thread main

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

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

2015-01-19 Thread Su She
(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.kafka$producer$SyncProducer$$doSend(SyncProducer.scala

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

2015-01-19 Thread Jaikiran Pai
$) 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.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:73

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

2015-01-19 Thread Su She
)] from broker [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