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

Compute lag correctly for optimized source changelogs

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 2.6.0
    • streams
    • None

    Description

      During KIP-441 we originally decided to leave the special handling of optimized source changelogs as a potential future improvement, since over-estimating lag was acceptable.

       

      But as always things have changed during the course of implementing this KIP, and the algorithm we ended up with requires accurate computation of lag. We should branch the lag computation in the assignor and use the correct end offset sum when computing lag

      Attachments

        Issue Links

          Activity

            People

              ableegoldman A. Sophie Blee-Goldman
              ableegoldman A. Sophie Blee-Goldman
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: