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)