GitHub user bondj opened a pull request:
https://github.com/apache/kafka/pull/1166
KAFKA-3205 Support passive close by broker
An attempt to fix KAFKA-3205. It appears the problem is that the broker
has closed the connection passively, and the client should react appropriately.
In NetworkReceive.readFrom() rather than throw an EOFException (Which means
the end of stream has been reached unexpectedly during input), instead return
the negative bytes read signifying an acceptable end of stream.
In Selector if the channel is being passively closed, don't try to read any
more data, don't try to write, and close the key.
I believe this will fix the problem.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bondj/kafka passiveClose
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1166.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1166
----
commit 5dc11015435a38a0d97efa2f46b4d9d9f41645b5
Author: Jonathan Bond <jb...@netflix.com>
Date: 2016-03-30T03:57:11Z
Support passive close by broker
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
