Got ClosedByInterruptException when closing ConsumerConnector

2015-02-09 Thread tao xiao
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$clas

Re: Got ClosedByInterruptException when closing ConsumerConnector

2015-02-09 Thread Guozhang Wang
Is this exception transient or consistent and blocking the shutdown process? On Mon, Feb 9, 2015 at 3:07 AM, tao xiao 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

Re: Got ClosedByInterruptException when closing ConsumerConnector

2015-02-09 Thread tao xiao
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 wrote: > Is this exception transient or consistent and blocking the shutdown > process? > > On Mon, Feb 9, 2015 at 3:07 AM, tao xiao wrote: > > > Hi team,

Re: Got ClosedByInterruptException when closing ConsumerConnector

2015-02-09 Thread Guozhang Wang
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 wrote: