Sophie Blee-Goldman created KAFKA-10085:
-------------------------------------------
Summary: Compute lag correctly for optimized source changelogs
Key: KAFKA-10085
URL: https://issues.apache.org/jira/browse/KAFKA-10085
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Sophie Blee-Goldman
Assignee: Sophie Blee-Goldman
Fix For: 2.6.0
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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
