[KAFKA-5936] KafkaProducer should not wrap InterruptedException in close() with KafkaException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0, 0.11.0.1, 1.0.0
• Fix Version/s: 1.1.0
• Component/s: clients
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 19/Sep/17 22:45
• Updated: 30/Nov/17 00:51
• Resolved: 30/Nov/17 00:46

Description

KafkaProducer.close() catches an InterruptedException when joining the sender thread and rethrows it later as a KafkaException. This prevent the interrupt signal to bubble out of the producer and thus, the caller might miss the interrupt.

We should rather throw our own org.apache.kafka.common.errors.InterruptException similar to KafkaConsumer.

Issue Links

• relates to: KAFKA-4767 KafkaProducer is not joining its IO thread properly
• links to: GitHub Pull Request #3912