[KAFKA-61] SimpleProducer lose messages when socket gets an io exception

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.6
• Assignee: Unassigned
• Reporter: Anonymous
• Created: 19/Jul/11 21:32
• Updated: 19/Jul/11 21:32
• Resolved: 19/Jul/11 21:32

Description

Currently, if we get any io exception while sending a message, SimpleProducer reestablishes the socket connection without resending the message. Thus the message is lost.

One way to fix this is to only reset socket channel to null when there is io exception during send and throw the exception back to the caller. The caller can capture the exception and resend the message.