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.