chirag-wadhwa5 opened a new pull request, #21246: URL: https://github.com/apache/kafka/pull/21246
Currently, when the start offset for a share partition is altered, the deliveryCompleteCount is set as -1. This results in a hyphenated lag, until the consumption begins, leading to some write states sent to the persister. But, when the start offset is altered to some non zero value, the system should be able to calculate the lag, irrespective of whether the consumption has begun or not from the new place. This PR resolves this by setting the deliveryCompleteCount to 0, whenever the start offset is changed to a non negative value. Test Results -> <img width="1726" height="928" alt="image" src="https://github.com/user-attachments/assets/35dc8b43-4590-4d80-868e-1764d7ceb2f8"; /> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
