kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rajini Sivaram (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5595) Illegal state in SocketServer; attempt to send with another send in progress
Date Sun, 16 Jul 2017 19:59:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089098#comment-16089098
] 

Rajini Sivaram commented on KAFKA-5595:
---------------------------------------

[~ijuma] I dont think the scenario that you described can occur. Broker mutes connections
when requests are processed. Even if client disconnected, the disconnection would be processed
only when the response was ready to be sent. And response is sent before any disconnections
are processed.

> Illegal state in SocketServer; attempt to send with another send in progress
> ----------------------------------------------------------------------------
>
>                 Key: KAFKA-5595
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5595
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jason Gustafson
>
> I have seen this a couple times, but I'm not sure the conditions associated with it.

> {code}
> 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)
> {code}
> Prior to this event, I see a lot of this message in the logs (always for the same connection
id):
> {code}
> Attempting to send response via channel for which there is no open connection, connection
id 7
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message