bozhao12 commented on code in PR #11965:
URL: https://github.com/apache/kafka/pull/11965#discussion_r841509645
##########
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##########
@@ -3719,3 +3767,19 @@ class ReplicaManagerTest {
}
}
}
+
+class MockReplicaSelector extends ReplicaSelector {
+
+ private val triggerSelectionCount = new AtomicLong()
+
+ def getTriggerSelectionCount: Long = triggerSelectionCount.get
+
+ /**
+ * Select the preferred replica a client should use for fetching. If no
replica is available, this will return an
+ * empty optional.
+ */
Review Comment:
@dajac Thanks for your review. All comments have been addressed.
--
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
