(kafka) branch trunk updated: MINOR: Fix grammatical typos in raft module messages (#22544)

[mimaison]

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

mimaison 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 09e36fdfd4f MINOR: Fix grammatical typos in raft module messages 
(#22544)
09e36fdfd4f is described below

commit 09e36fdfd4f025f4c6fd71a0e9e476f88d888b28
Author: LeiXiaoGao <2995484...@qq.com>
AuthorDate: Fri Jun 19 16:35:36 2026 +0800

    MINOR: Fix grammatical typos in raft module messages (#22544)
    
    
    Reviewers: Mickael Maison <mickael.mai...@gmail.com>, Ken Huang 
<s7133...@gmail.com>
---
 raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java        | 2 +-
 raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java 
b/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
index f7091cac1ec..824a4c4a8ba 100644
--- a/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
+++ b/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
@@ -3586,7 +3586,7 @@ public final class KafkaRaftClient<T> implements 
RaftClient<T> {
             }
         } else {
             if (listenerContexts.remove(listener) == null) {
-                logger.error("Attempting to remove a listener that doesn't 
exists: {}", listenerName(listener));
+                logger.error("Attempting to remove a listener that doesn't 
exist: {}", listenerName(listener));
             } else {
                 logger.info("Unregistered the listener {}", 
listenerName(listener));
             }
diff --git 
a/raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java 
b/raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java
index 4334d0a6d82..89eea74b4a7 100644
--- a/raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java
+++ b/raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java
@@ -780,7 +780,7 @@ public class KafkaRaftLog implements RaftLog {
                 }
                 if (latestSnapshotId.isEmpty() || 
latestSnapshotId.get().offset() < log.logStartOffset()) {
                     throw new IllegalStateException("Inconsistent snapshot 
state: there must be a snapshot " +
-                            "at an offset larger then the current log start 
offset " + log.logStartOffset() +
+                            "at an offset larger than the current log start 
offset " + log.logStartOffset() +
                             ", but the latest snapshot is " + 
latestSnapshotId);
                 }
             }