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