Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-15327

Client consumer should commit offsets on close

    XMLWordPrintableJSON

Details

    Description

      In the current implementation of the KafkaConsumer, the ConsumerCoordinator commits offsets before the consumer is closed, with a call to 
      maybeAutoCommitOffsetsSync(timer);
      The async consumer should provide the same behaviour to commit offsets on close. 

      This fix should allow to successfully run the following integration tests (defined in PlaintextConsumerTest)

      • testAutoCommitOnClose
      • testAutoCommitOnCloseAfterWakeup

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue KAFKA-15865 Ensure consumer.poll() execute autocommit callback

          • Major - Major loss of function.
          • Resolved
          is part of

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-14246 Update threading model for Consumer

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #14710

          Activity

            People

              pnee Philip Nee
              lianetm Lianet Magrans
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: