From 4e1a23d9487e97d6b394627a828e95401bd5e387 Mon Sep 17 00:00:00 2001 From: "Gyeongwon, Do" Date: Wed, 17 Apr 2024 01:06:43 +0900 Subject: [PATCH] MINOR: Fix typo in OffsetCommitCallbackInvoker's javadoc (#15643) Reviewers: Mickael Maison , Johnny Hsu --- .../clients/consumer/internals/OffsetCommitCallbackInvoker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java index 47a5df6d1d20b..3c1ebc6dec3a5 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java @@ -25,7 +25,7 @@ import java.util.concurrent.LinkedBlockingQueue; /** - * Utility class that helps the application thread to invoke user registered {@link OffsetCommitCallback} amd + * Utility class that helps the application thread to invoke user registered {@link OffsetCommitCallback} and * {@link org.apache.kafka.clients.consumer.ConsumerInterceptor}s. This is * achieved by having the background thread register a {@link OffsetCommitCallbackTask} to the invoker upon the * future completion, and execute the callbacks when user polls/commits/closes the consumer.