mannoopj opened a new pull request, #21453: URL: https://github.com/apache/kafka/pull/21453
RaftClient.java — Added handleLoadBootstrap as an abstract method in RaftClient.Listener, updated javadocs for handleLoadSnapshot (now specifies "committed snapshot") and handleLeaderChange SnapshotReader.java — Added isCommittedSnapshot() method to the interface RecordsSnapshotReader.java — Added isCommittedSnapshot field, constructor parameter, method implementation, and a new of() overload that auto-detects bootstrap snapshots via BOOTSTRAP_SNAPSHOT_ID KafkaRaftClient.java — Routes snapshot loading to handleLoadBootstrap or handleLoadSnapshot based on isCommittedSnapshot() QuorumController.java — Added handleLoadBootstrap method with full replay logic for bootstrap snapshots, made bootstrapMetadata volatile MetadataLoader.java — Added handleLoadBootstrap that closes the reader (bootstrap metadata is handled by QuorumController) MetadataLoaderTest.java — Added isCommittedSnapshot support to MockSnapshotReader MockRaftClientListener.java — Added handleLoadBootstrap implementation ReplicatedCounter.java — Added handleLoadBootstrap implementation RaftClientTestContext.java — Added handleLoadBootstrap to MockListener -- 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]
