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

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0.1
• Fix Version/s: 0.10.1.0
• Component/s: core
• Assignee: TAO XIAO
• Reporter: TAO XIAO
• Created: 06/Sep/16 13:05
• Updated: 07/Sep/16 00:18
• Resolved: 07/Sep/16 00:17

Description

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

        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)

Issue Links

• links to: GitHub Pull Request #1826