(kafka) branch trunk updated: MINOR: Fix the typo in RaftEventSimulationTest.java and ControllerNode.java (#16591)

[chia7712]

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

chia7712 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 15eb555b031 MINOR: Fix the typo in RaftEventSimulationTest.java and 
ControllerNode.java (#16591)
15eb555b031 is described below

commit 15eb555b031b87ba29d4ca776192b166a630f5e0
Author: Volk <46952458+sorav...@users.noreply.github.com>
AuthorDate: Mon Jul 15 18:15:22 2024 +0800

    MINOR: Fix the typo in RaftEventSimulationTest.java and ControllerNode.java 
(#16591)
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java   | 2 +-
 raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java 
b/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
index 13f12034fb2..31d696484f3 100644
--- a/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
+++ b/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
@@ -732,7 +732,7 @@ public final class RaftClientTestContext {
         ObjectSerializationCache cache =  new ObjectSerializationCache();
         ByteArrayOutputStream  buffer = new 
ByteArrayOutputStream(message.size(cache, version));
 
-        // Endode the message to a byte array with the given version
+        // Encode the message to a byte array with the given version
         DataOutputStreamWritable writer = new DataOutputStreamWritable(new 
DataOutputStream(buffer));
         message.write(writer, cache, version);
 
diff --git 
a/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java 
b/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
index 6e9f364c8e3..c57c441b98b 100644
--- a/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
+++ b/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
@@ -947,7 +947,7 @@ public class RaftEventSimulationTest {
          * Returns if the message should be sent to the destination.
          *
          * Returns false when outbound request messages contains a destination 
{@code Node} that
-         * matches the set of unreaable {@code InetSocketAddress}. Note that 
the {@code Node.id()}
+         * matches the set of unreachable {@code InetSocketAddress}. Note that 
the {@code Node.id()}
          * and {@code Node.rack()} are not compared.
          *
          * @param message the raft message
@@ -1114,7 +1114,7 @@ public class RaftEventSimulationTest {
                         assertEquals(
                             logStartOffset,
                             earliestSnapshotId.offset(),
-                            () -> String.format("mising snapshot at log start 
offset: nodeId = %s", nodeId)
+                            () -> String.format("missing snapshot at log start 
offset: nodeId = %s", nodeId)
                         );
                     }
                 });