cmccabe commented on code in PR #14132:
URL: https://github.com/apache/kafka/pull/14132#discussion_r1283658739
##########
metadata/src/main/java/org/apache/kafka/controller/LogReplayTracker.java:
##########
@@ -17,56 +17,516 @@
package org.apache.kafka.controller;
-import org.apache.kafka.common.protocol.ApiMessage;
+import org.apache.kafka.common.metadata.AbortTransactionRecord;
+import org.apache.kafka.common.metadata.BeginTransactionRecord;
+import org.apache.kafka.common.metadata.EndTransactionRecord;
import org.apache.kafka.common.utils.LogContext;
+import org.apache.kafka.common.utils.Time;
+import org.apache.kafka.controller.metrics.QuorumControllerMetrics;
+import org.apache.kafka.raft.LeaderAndEpoch;
+import org.apache.kafka.server.fault.FaultHandler;
+import org.apache.kafka.timeline.SnapshotRegistry;
import org.slf4j.Logger;
+import java.util.Optional;
+import java.util.OptionalInt;
+import java.util.function.BiConsumer;
+import java.util.function.Consumer;
+
/**
* The LogReplayTracker manages state associated with replaying the metadata
log, such as whether
* we have seen any records. It is accessed solely from the quorum controller
thread.
*/
-public class LogReplayTracker {
- public static class Builder {
+class LogReplayTracker {
+ static class Builder {
private LogContext logContext = null;
+ private Time time = Time.SYSTEM;
+ private int nodeId = -1;
+ private QuorumControllerMetrics metrics = null;
+ private Consumer<Integer> gainLeadershipCallback = __ -> { };
+ private Consumer<Integer> loseLeadershipCallback = __ -> { };
+ private BiConsumer<Long, String> revertCallback = (__, ___) -> { };
Review Comment:
ok
--
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
