Skip to content

KAFKA-19402: Typo in EventAccumulator.java #19951

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Jun 20, 2025
Merged

KAFKA-19402: Typo in EventAccumulator.java #19951

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
5b45a49
fix typo in EventAccumulator.java
masonyc Jun 12, 2025
8fb3a39
Update coordinator-common/src/main/java/org/apache/kafka/coordinator/…
masonyc Jun 20, 2025
5fe8cfe
Fix grammar in EventAccumulator.java
masonyc Jun 20, 2025
f2ca6f6
Fix typi EventAccumulator.java
masonyc Jun 20, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions ...or-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
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.
*
Expand Down Expand Up @@ -90,7 +90,7 @@ public interface Event<K> {
private int size;

/**
* A boolean indicated whether the accumulator is closed.
* A boolean indicating whether the accumulator is closed.
*/
private boolean closed;

Expand Down Expand Up @@ -174,7 +174,7 @@ public T poll() {

/**
* 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.
Expand Down