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

Ensure ClassicKafkaConsumer sends leave request on close even if interrupted

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 3.8.0, 3.9.0
    • None
    • clients, consumer

    Description

      During testing for KAFKA-16985, a new, parameterized integration test was added to PlaintextConsumerTest named testCloseLeavesGroupOnInterrupt(). When the test is executed locally, it passes using both the AsyncKafkaConsumer and the ClassicKafkaConsumer. However, when the test is run in the Apache CI environment, it passes for the AsyncKafkaConsumer but fails for the ClassicKafkaConsumer. Rather than hold up KAFKA-16985, this Jira was filed to investigate and fix the ClassicKafkaConsumer.

      Attachments

        Issue Links

          relates to

          Test - A new unit, integration or system test. KAFKA-18031 Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Open

          Activity

            People

              Unassigned Unassigned
              kirktrue Kirk True
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: