Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-16092 Queues for Kafka
  3. KAFKA-18016

Fix bugs in handling piggyback acknowledgements in ShareFetch

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 4.0.0
    • None
    • None

    Description

      Currently, when a ShareFetch is processed and response is received, we use the fetchAcknowledgements map to determine the acknowledgements sent per partition and call the callback accordingly. But there is a chance this map was updated by the ShareFetchEvent before the response was processed.
      This means we could potentially lose out on sending acknowledgements. This bug was found while testing using the ShareRoundTripWorker with 100k records and a target production rate of 1000 messages per second.

      Attachments

        Issue Links

          Activity

            People

              shivsundar Shivsundar R
              shivsundar Shivsundar R
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: