kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: high level consumer shutdown exception
Date Mon, 21 Apr 2014 05:11:55 GMT
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 <zhaoyonghui@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)
>

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