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

Reply via email to