[ https://issues.apache.org/jira/browse/KAFKA-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma updated KAFKA-2938: ------------------------------- Fix Version/s: (was: 0.9.0.1) > 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 > > 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)