Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> java.nio.channels.ClosedChannelException


Copy link to this message
-
Re: java.nio.channels.ClosedChannelException
Jun,

Since all the concerned servers (brokers and producers) are on EC2 I
thought this won't apply to me. Internal IP should work within EC2, right?

Regards,
Vaibhav

On Fri, Apr 27, 2012 at 4:04 PM, Jun Rao <[EMAIL PROTECTED]> wrote:

> It seems that you are using ZK-based producer. You may want to look at item
> 2 in http://incubator.apache.org/kafka/faq.html. That problem applies to
> the producer too if ZK is used.
>
> Thanks,
>
> Jun
>
> On Fri, Apr 27, 2012 at 2:45 PM, Vaibhav Puranik <[EMAIL PROTECTED]>
> wrote:
>
> > HI all,
> >
> > We are trying out Kafka currently. We are running Kafka 0.7 on 3 EC2
> > instances (c1.xlarge) with one zookeeper.
> > The clients and servers both are on EC2.
> >
> > Here is what we are getting :
> >
> >
> >   1. java.nio.channels.ClosedChannelException
> >   2.         at
> >
> sun.nio.ch.SocketChannelImpl.ensureWriteOpen(SocketChannelImpl.java:126)
> >   3.         at
> >   sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:324)
> >   4.         at
> >
> >
> kafka.network.BoundedByteBufferSend.writeTo(BoundedByteBufferSend.scala:48)
> >
> >
> > The full exception is here:
> >
> > http://pastebin.com/TnypFpCY
> >
> >
> > The Kafka broker logs doesn't have anything unusual - It's as if the
> > requests are not even reaching to Kafka.
> >
> > Any pointers?
> >
> > Regards,
> > Vaibhav Puranik
> > GumGum
> >
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB