Jason Gustafson created KAFKA-2266:
--------------------------------------
Summary: Client Selector can drop idle connections without
notifying NetworkClient
Key: KAFKA-2266
URL: https://issues.apache.org/jira/browse/KAFKA-2266
Project: Kafka
Issue Type: Bug
Reporter: Jason Gustafson
Assignee: Jason Gustafson
I've run into this while testing the new consumer. The class
org.apache.kafka.common.networ.Selector has code to drop idle connections, but
when one is dropped, it is not added to the list of disconnections. This causes
inconsistency between Selector and NetworkClient, which depends on this list to
update its internal connection states. When a new request is sent to
NetworkClient, it still sees the connection as good and forwards it to
Selector, which results in an IllegalStateException.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)