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)
