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

KafkaConsumer.close() may block indefinitely

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Duplicate
    • None
    • None
    • None
    • None

    Description

      KafkaConsumer API doc states 

      Close the consumer, waiting indefinitely for any needed cleanup. . . .

      That is not acceptable as it creates an artificial deadlock which directly affects systems that rely on Kafka API essentially rendering them unavailable.

      Consider adding close(timeout) method

      Attachments

        Issue Links

          is duplicated by

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-4426 Add consumer.close(timeout, unit) for graceful close with timeout

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              Unassigned Unassigned
              ozhurakousky Oleg Zhurakousky
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: