Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15306

Integrate committed offsets logic when updating fetching positions

    XMLWordPrintableJSON

Details

    Description

      Integrate refreshCommittedOffsets logic, currently performed by the coordinator, into the update fetch positions performed on every iteration of the async consumer poll loop. This should rely on the CommitRequestManager to perform the request based on the refactored model, but it should reuse the logic for processing the committed offsets and updating the positions. 

      Attachments

        Issue Links

          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 #14385

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: