(kafka) branch trunk updated: KAFKA-19402: Typo in EventAccumulator.java (#19951)

[lianetm]

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

lianetm 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 d442c31e926 KAFKA-19402: Typo in EventAccumulator.java (#19951)
d442c31e926 is described below

commit d442c31e9267b823d36658070fe46533e4d7c68d
Author: Mason Chen <mason.yunc...@gmail.com>
AuthorDate: Fri Jun 20 22:34:02 2025 +0300

    KAFKA-19402: Typo in EventAccumulator.java (#19951)
    
    Fix multiple typo and grammar issues in EventAccumulator.java
    
    Reviewers: Jhen-Yung Hsu <jhenyung...@gmail.com>, Lianet Magrans
     <lmagr...@confluent.io>
    
    ---------
    
    Co-authored-by: Lianet Magrans <98415067+lian...@users.noreply.github.com>
---
 .../apache/kafka/coordinator/common/runtime/EventAccumulator.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
 
b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
index e6386e35f9d..985fb488344 100644
--- 
a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
+++ 
b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
@@ -32,8 +32,8 @@ import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.ReentrantLock;
 
 /**
- * A concurrent event accumulator which group events per key and ensure that 
only one
- * event with a given key can't be processed concurrently.
+ * A concurrent event accumulator which groups events per key and ensures that 
only one
+ * event with a given key can be processed concurrently.
  *
  * This class is threadsafe.
  *
@@ -90,7 +90,7 @@ public class EventAccumulator<K, T extends 
EventAccumulator.Event<K>> implements
     private int size;
 
     /**
-     * A boolean indicated whether the accumulator is closed.
+     * A boolean indicating whether the accumulator is closed.
      */
     private boolean closed;
 
@@ -174,7 +174,7 @@ public class EventAccumulator<K, T extends 
EventAccumulator.Event<K>> implements
 
     /**
      * Returns the next {{@link Event}} available. This method blocks for the 
provided
-     * time and returns null of no event is available.
+     * time and returns null if no event is available.
      *
      * @param timeout   The timeout.
      * @param unit      The timeout unit.