apoorvmittal10 opened a new pull request, #20738: URL: https://github.com/apache/kafka/pull/20738
The PR fixes couple of issues which are related to the batch alignment: 1. Base offset not found for some acquisition lock timeouts. 2. Gaps reported by client when the topic cannot have any gaps. The root cause was the misaligned batches when cache is full but the fetch happens in middle of cached offsets i.e. some records are released because of acquisition lock time out or expilicitly. As the subsequent fetch can have lesser bytes of data but the method `lastOffsetAndMaxRecordsToAcquire` aligned the lastOffsetToAcquire to `endOffset` hence incorrect batches were created. The PR fixes that by adding a `min` comparison. -- 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]
