[KAFKA-5595] Illegal state in SocketServer; attempt to send with another send in progress

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Rajini Sivaram
• Reporter: Jason Gustafson
• Created: 14/Jul/17 18:25
• Updated: 25/Aug/17 08:27
• Resolved: 25/Aug/17 08:27

Description

I have seen this a couple times, but I'm not sure the conditions associated with it.

java.lang.IllegalStateException: Attempt to begin a send operation with prior send operation still in progress.
	at org.apache.kafka.common.network.KafkaChannel.setSend(KafkaChannel.java:138)
	at org.apache.kafka.common.network.Selector.send(Selector.java:248)
	at kafka.network.Processor.sendResponse(SocketServer.scala:488)
	at kafka.network.Processor.processNewResponses(SocketServer.scala:466)
	at kafka.network.Processor.run(SocketServer.scala:431)
	at java.lang.Thread.run(Thread.java:748)

Prior to this event, I see a lot of this message in the logs (always for the same connection id):

Attempting to send response via channel for which there is no open connection, connection id 7

Issue Links

• links to: GitHub Pull Request #3530