kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: Got ClosedByInterruptException when closing ConsumerConnector
Date Tue, 10 Feb 2015 02:19:10 GMT
This exception should be transient (and that is why we captured it as INFO
level log entries) and can be ignored.

We are currently working on the new consumer APIs, and will improve our
logging pattern to avoid such confusing information.

Guozhang

On Mon, Feb 9, 2015 at 5:33 PM, tao xiao <xiaotao183@gmail.com> wrote:

> It happens every time I shutdown the connector. It doesn't block the
> shutdown process though
>
> On Tue, Feb 10, 2015 at 1:09 AM, Guozhang Wang <wangguoz@gmail.com> wrote:
>
> > Is this exception transient or consistent and blocking the shutdown
> > process?
> >
> > On Mon, Feb 9, 2015 at 3:07 AM, tao xiao <xiaotao183@gmail.com> wrote:
> >
> > > Hi team,
> > >
> > > I got java.nio.channels.ClosedByInterruptException when
> > > closing ConsumerConnector using kafka 0.8.2
> > >
> > > Here is the exception
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [test12345_localhost], ZKConsumerConnector shutting down
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherManager-1423479848796] Stopping leader finder thread
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [test12345_localhost], Shutting down
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [test12345_localhost], Shutdown completed
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherManager-1423479848796] Stopping all fetchers
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [test12345_localhost], Stopped
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherThread-test12345_localhost], Shutting down
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 - Reconnect due
> to
> > > socket error: java.nio.channels.ClosedByInterruptException
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherThread-test12345_localhost], Stopped
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherThread-test12345_localhost], Shutdown completed
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [ConsumerFetcherManager-1423479848796] All connections stopped
> > >
> > > 2015-02-09 19:04:19 INFO  org.I0Itec.zkclient.ZkEventThread:82 -
> > Terminate
> > > ZkClient event thread.
> > >
> > > 2015-02-09 19:04:19 INFO  org.apache.zookeeper.ZooKeeper:684 - Session:
> > > 0x14b6dd8fcf80011 closed
> > >
> > > 2015-02-09 19:04:19 INFO
> > org.apache.zookeeper.ClientCnxn$EventThread:512 -
> > > EventThread shut down
> > >
> > > 2015-02-09 19:04:19 INFO  kafka.utils.Logging$class:68 -
> > > [test12345_localhost], ZKConsumerConnector shutdown completed in 86 ms
> > >
> > >
> > > --
> > > Regards,
> > > Tao
> > >
> >
> >
> >
> > --
> > -- Guozhang
> >
>
>
>
> --
> Regards,
> Tao
>



-- 
-- Guozhang

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message