[kafka] branch trunk updated: MINOR: Fix typo in info message (#12665)

[sh...@apache.org]

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 9df925bf9e MINOR: Fix typo in info message (#12665)
9df925bf9e is described below

commit 9df925bf9e9df2bb9d0c5554558804f84c549992
Author: Philipp Trulson <de...@users.noreply.github.com>
AuthorDate: Wed Sep 21 04:05:15 2022 +0200

    MINOR: Fix typo in info message (#12665)
    
    Reviewers: Luke Chen <sh...@gmail.com>
---
 core/src/main/scala/kafka/server/AbstractFetcherThread.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
index 2ae3f45023..9701f55264 100755
--- a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
@@ -292,7 +292,7 @@ abstract class AbstractFetcherThread(name: String,
         markPartitionFailed(tp)
         false
       } else {
-        info(s"Partition $tp has an new epoch ($currentLeaderEpoch) than the current leader. retry the partition later")
+        info(s"Partition $tp has a newer epoch ($currentLeaderEpoch) than the current leader. Retry the partition later.")
         true
       }
     }