GitHub user llowrey opened a pull request:
https://github.com/apache/kafka/pull/1083
KAFKA-3378 Fix for instantly connecting SocketChannels (v2)
Alternative implementation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/llowrey
GitHub user llowrey opened a pull request:
https://github.com/apache/kafka/pull/1085
KAFKA-3378 Fix for instantly connecting SocketChannels (v3)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/llowrey/kafka trunk
Alternatively
GitHub user llowrey opened a pull request:
https://github.com/apache/kafka/pull/1044
KAFKA-3378 Fix for instantly connecting SocketChannels.
Added OP_WRITE interestOp when channel connects instantly
(socketChannel.connect(address) returns true... even in non-blocking mode).
This