You are talking about the broker side exception in Processor? That can happen on a consumer shutdown.
Thanks, Jun On Sat, Apr 19, 2014 at 6:16 AM, Yonghui Zhao <zhaoyong...@gmail.com> wrote: > In kafka 0.8.1, when I shut down high level consumer, I found one > exception. > I think it is expected, right? > > > 14/04/19 21:12:47 INFO consumer.ZookeeperConsumerConnector: > [1_yozhao-ubuntu-1397913156352-9b13f962], ZKConsumerConnector shutting down > 14/04/19 21:12:47 INFO zookeeper.ClientCnxn: Client session timed out, have > not heard from server in 11171ms for sessionid 0x1457a1df4670000, closing > socket connection and attempting reconnect > 14/04/19 21:12:47 INFO zookeeper.ClientCnxn: Client session timed out, have > not heard from server in 10741ms for sessionid 0x1457a1df4670001, closing > socket connection and attempting reconnect > 14/04/19 21:12:47 WARN server.NIOServerCnxn: EndOfStreamException: Unable > to read additional data from client sessionid 0x1457a1df4670000, likely > client has closed socket > 14/04/19 21:12:47 INFO server.NIOServerCnxn: Closed socket connection for > client /127.0.0.1:57088 which had sessionid 0x1457a1df4670000 > 14/04/19 21:12:47 WARN server.NIOServerCnxn: EndOfStreamException: Unable > to read additional data from client sessionid 0x1457a1df4670001, likely > client has closed socket > 14/04/19 21:12:47 INFO server.NIOServerCnxn: Closed socket connection for > client /127.0.0.1:57096 which had sessionid 0x1457a1df4670001 > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherManager: > [ConsumerFetcherManager-1397913156371] Stopping leader finder thread > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherManager$LeaderFinderThread: > [1_yozhao-ubuntu-1397913156352-9b13f962-leader-finder-thread], Shutting > down > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherManager$LeaderFinderThread: > [1_yozhao-ubuntu-1397913156352-9b13f962-leader-finder-thread], Stopped > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherManager$LeaderFinderThread: > [1_yozhao-ubuntu-1397913156352-9b13f962-leader-finder-thread], Shutdown > completed > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherManager: > [ConsumerFetcherManager-1397913156371] Stopping all fetchers > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherThread: > [ConsumerFetcherThread-1_yozhao-ubuntu-1397913156352-9b13f962-0-0], > Shutting down > 14/04/19 21:12:47 WARN consumer.SimpleConsumer: Reconnect due to socket > error: null > 14/04/19 21:12:47 INFO zkclient.ZkClient: zookeeper state changed > (Disconnected) > 14/04/19 21:12:47 INFO zkclient.ZkClient: zookeeper state changed > (Disconnected) > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherThread: > [ConsumerFetcherThread-1_yozhao-ubuntu-1397913156352-9b13f962-0-0], Stopped > 14/04/19 21:12:47 INFO consumer.ConsumerFetcherThread: > [ConsumerFetcherThread-1_yozhao-ubuntu-1397913156352-9b13f962-0-0], > Shutdown completed > 14/04/19 21:12:47 ERROR network.Processor: Closing socket for > /10.237.113.65because of error > *java.io.IOException: Connection reset by peer* > at sun.nio.ch.FileDispatcher.read0(Native Method) > at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21) > at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198) > at sun.nio.ch.IOUtil.read(IOUtil.java:171) > at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243) > at kafka.utils.Utils$.read(Utils.scala:375) > at > > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) > at kafka.network.Processor.read(SocketServer.scala:347) > at kafka.network.Processor.run(SocketServer.scala:245) > at java.lang.Thread.run(Thread.java:662) >
