[
https://issues.apache.org/jira/browse/KAFKA-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16087916#comment-16087916
]
Rajini Sivaram edited comment on KAFKA-5595 at 7/14/17 7:56 PM:
----------------------------------------------------------------
Connection id contains remote port, it is currently logging processor id, hence
the integer value 7 in the logs. I have submitted a PR to fix that.
[~ijuma] Since connection id contains remote port, for the scenario you
described, the port needs to get reused. Typically that shouldn't happen while
still processing requests of an older connection using that port. In theory, I
suppose it could happen if there lots of connections being created and closed.
was (Author: rsivaram):
Connection id contains remote port, it is currently logging processor id, hence
the integer value 7 in the logs. I have submitted a PR to fix that.
[~ijuma] Since connection id contains remote port, for the scenario you
described, the port needs to get reused. Typically that shouldn't happen while
still processing requests of an older connection using that port. The channel
should have been closed and removed from selector before the new connection.
> 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)
