From 6b0bb1e302e89de3c759538df667979698a11892 Mon Sep 17 00:00:00 2001 From: Tran Ngoc Nhan Date: Sun, 12 Oct 2025 19:37:04 +0700 Subject: [PATCH] Fix typo Signed-off-by: Tran Ngoc Nhan --- .../kafka/listener/KafkaMessageListenerContainer.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java index 6364135b12..7b41d6ded5 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java @@ -1475,7 +1475,7 @@ protected void pollAndInvoke() { invokeIfHaveRecords(records); if (this.remainingRecords == null) { - resumeConsumerIfNeccessary(); + resumeConsumerIfNecessary(); if (!this.consumerPaused) { resumePartitionsIfNecessary(); } @@ -1830,7 +1830,7 @@ private void doPauseConsumerIfNecessary() { } } - private void resumeConsumerIfNeccessary() { + private void resumeConsumerIfNecessary() { if (this.nackWakeTimeMillis > 0) { if (System.currentTimeMillis() > this.nackWakeTimeMillis) { this.nackWakeTimeMillis = 0; @@ -1842,15 +1842,15 @@ private void resumeConsumerIfNeccessary() { } else if (this.offsetsInThisBatch != null) { synchronized (this) { - doResumeConsumerIfNeccessary(); + doResumeConsumerIfNecessary(); } } else { - doResumeConsumerIfNeccessary(); + doResumeConsumerIfNecessary(); } } - private void doResumeConsumerIfNeccessary() { + private void doResumeConsumerIfNecessary() { if (this.pausedForAsyncAcks && Objects.requireNonNull(this.offsetsInThisBatch).isEmpty()) { this.pausedForAsyncAcks = false; this.logger.debug("Resuming after manual async acks cleared");