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)

Reply via email to