[KAFKA-2938] Socket server may throw IllegalStateException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 0.9.0.0
• Component/s: network
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 02/Dec/15 23:56
• Updated: 13/Feb/16 12:45
• Resolved: 03/Dec/15 05:00

Description

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.