This is an automated email from the ASF dual-hosted git repository.

showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new b4f35c9ce0 MINOR: Fix typo in ReplicaManagerTest (#12178)
b4f35c9ce0 is described below

commit b4f35c9ce0ec902123fa6b5ad7c84c63118c7358
Author: bozhao12 <[email protected]>
AuthorDate: Thu May 19 10:28:47 2022 +0800

    MINOR: Fix typo in ReplicaManagerTest (#12178)
    
    Reviewer: Luke Chen <[email protected]>
---
 core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala 
b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
index aa28ce7269..977da6c69c 100644
--- a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
+++ b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
@@ -3374,7 +3374,7 @@ class ReplicaManagerTest {
     val replicaManager = setupReplicaManagerWithMockedPurgatories(new 
MockTimer(time), localId)
 
     try {
-      // Make the local replica the follower
+      // Make the local replica the leader
       val leaderTopicsDelta = topicsCreateDelta(localId, true)
       val leaderMetadataImage = imageFromTopics(leaderTopicsDelta.apply())
       replicaManager.applyDelta(leaderTopicsDelta, leaderMetadataImage)
@@ -3411,7 +3411,7 @@ class ReplicaManagerTest {
     val replicaManager = setupReplicaManagerWithMockedPurgatories(new 
MockTimer(time), localId)
 
     try {
-      // Make the local replica the follower
+      // Make the local replica the leader
       val leaderTopicsDelta = topicsCreateDelta(localId, true)
       val leaderMetadataImage = imageFromTopics(leaderTopicsDelta.apply())
       replicaManager.applyDelta(leaderTopicsDelta, leaderMetadataImage)

Reply via email to