You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2015/12/03 00:57:11 UTC

[jira] [Created] (KAFKA-2938) Socket server may throw IllegalStateException

Jiangjie Qin created KAFKA-2938:
-----------------------------------

             Summary: Socket server may throw IllegalStateException
                 Key: KAFKA-2938
                 URL: https://issues.apache.org/jira/browse/KAFKA-2938
             Project: Kafka
          Issue Type: Bug
          Components: network
    Affects Versions: 0.9.0.0
            Reporter: Jiangjie Qin
            Assignee: Jiangjie Qin
             Fix For: 0.9.0.1


The Processor in SocketServer will try to drain all the responses in the response queue and pass them to selector for sending. 

If there are more than one response in the response queue (e.g. a producer with max in flight request greater than 1), an IllegalStateException would be thrown because the processor will call selector.send() before the previous send is finished.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)