[jira] [Created] (KAFKA-4129) Processor throw exception when getting channel remote address after closing the channel

["TAO XIAO (JIRA)" <ji...@apache.org>]

TAO XIAO created KAFKA-4129:
-------------------------------

             Summary: Processor throw exception when getting channel remote address after closing the channel
                 Key: KAFKA-4129
                 URL: https://issues.apache.org/jira/browse/KAFKA-4129
             Project: Kafka
          Issue Type: Bug
          Components: core
    Affects Versions: 0.10.0.1
            Reporter: TAO XIAO
            Assignee: TAO XIAO


In Processor {{configureNewConnections()}} catch block, it explicitly closes {{channel}} before calling {{channel.getRemoteAddress}} which results in {{ClosedChannelException}} being thrown. This is due to Java implementation that no remote address can be returned after the channel is closed

{code}
        case NonFatal(e) =>
         // need to close the channel here to avoid a socket leak.
         close(channel)
         error(s"Processor $id closed connection from ${channel.getRemoteAddress}", e)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)