@@ -1475,7 +1475,7 @@ protected void pollAndInvoke() {
14751475
14761476 invokeIfHaveRecords (records );
14771477 if (this .remainingRecords == null ) {
1478- resumeConsumerIfNeccessary ();
1478+ resumeConsumerIfNecessary ();
14791479 if (!this .consumerPaused ) {
14801480 resumePartitionsIfNecessary ();
14811481 }
@@ -1830,7 +1830,7 @@ private void doPauseConsumerIfNecessary() {
18301830 }
18311831 }
18321832
1833- private void resumeConsumerIfNeccessary () {
1833+ private void resumeConsumerIfNecessary () {
18341834 if (this .nackWakeTimeMillis > 0 ) {
18351835 if (System .currentTimeMillis () > this .nackWakeTimeMillis ) {
18361836 this .nackWakeTimeMillis = 0 ;
@@ -1842,15 +1842,15 @@ private void resumeConsumerIfNeccessary() {
18421842 }
18431843 else if (this .offsetsInThisBatch != null ) {
18441844 synchronized (this ) {
1845- doResumeConsumerIfNeccessary ();
1845+ doResumeConsumerIfNecessary ();
18461846 }
18471847 }
18481848 else {
1849- doResumeConsumerIfNeccessary ();
1849+ doResumeConsumerIfNecessary ();
18501850 }
18511851 }
18521852
1853- private void doResumeConsumerIfNeccessary () {
1853+ private void doResumeConsumerIfNecessary () {
18541854 if (this .pausedForAsyncAcks && Objects .requireNonNull (this .offsetsInThisBatch ).isEmpty ()) {
18551855 this .pausedForAsyncAcks = false ;
18561856 this .logger .debug ("Resuming after manual async acks cleared" );
0 commit comments