ddcprg commented on issue #9091: URL: https://github.com/apache/pinot/issues/9091#issuecomment-1192930100
Many thanks @Jackie-Jiang @richardstartin I was thinking a solution around the same lines as the one proposed by @richardstartin we could update a counter (or keep the index itself) in `MessageBatch` with every fetch of the next record and that can then be compared with the size of the list, this would tell us if the whole batch has been processed. This counter/index could also help in computing the offset for the next batch. Not sure if this makes sense, let me know your thoughts -- 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
