mumrah opened a new pull request, #15283: URL: https://github.com/apache/kafka/pull/15283
Rather than immediately publishing a MetadataDelta for each commit handled from the Raft layer, this patch uses a short deferral window for accumulating changes from multiple Raft commits. A deferred event is enqueued after handling a commit from Raft which will flush the metadata buffered in MetadataBatchLoader. Only a single deferred event is enqueued at any given time. When handling snapshots, the deferred event is cancelled and MetadataBatchLoader is immediately flushed. This is to ensure proper serialization of the metadata publishings. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
