KKcorps opened a new pull request, #8612: URL: https://github.com/apache/pinot/pull/8612
Currently, Pulsar batch message ids to start the consumer are calculated by assuming each batch is of exact BATCH_SIZE. However, in pulsar producer configuration, that is the max size and sometimes the actual batches can be smaller than the particular size. The only way is to keep track of all batch ids in a map. This will help reduce the instances of flakiness in the future. -- 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: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org