Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5936

KafkaProducer should not wrap InterruptedException in close() with KafkaException

    XMLWordPrintableJSON

    Details

    • 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
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mjsax Matthias J. Sax
                Reporter:
                mjsax Matthias J. Sax
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: