[KAFKA-907] controller needs to close socket channel to brokers on exception

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Fix Version/s: 0.8.0
• Assignee: Jun Rao
• Reporter: Jun Rao
• Created: 15/May/13 23:03
• Updated: 22/May/13 23:31
• Resolved: 22/May/13 23:24

Description

When the controller sends a request to a broker (e.g., leaderAndIsrRequest), it may hit a exception (e.g. SocketTimeException). When this happens, the socket channel needs to be closed and recreated.