abhijeetk88 commented on code in PR #16834:
URL: https://github.com/apache/kafka/pull/16834#discussion_r1719655730
##########
server/src/main/java/org/apache/kafka/server/config/ReplicationConfigs.java:
##########
@@ -136,6 +136,10 @@ public class ReplicationConfigs {
public static final String REPLICA_SELECTOR_CLASS_CONFIG =
"replica.selector.class";
public static final String REPLICA_SELECTOR_CLASS_DOC = "The fully
qualified class name that implements ReplicaSelector. This is used by the
broker to find the preferred read replica. By default, we use an implementation
that returns the leader.";
+ public static final String FOLLOWER_FETCH_LAST_TIERED_OFFSET_ENABLE_CONFIG
= "follower.fetch.last.tiered.offset.enable";
+ public static final String FOLLOWER_FETCH_LAST_TIERED_OFFSET_ENABLE_DOC =
"If enabled, an empty follower will skip replicating offsets up to the last
tiered offset and start from the next offset.";
Review Comment:
I wanted to update the KIP as well - The last tiered offset is actually not
the start offset for the follower. It is the next offset.
--
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]
