Consumer crashed if delay is more than maxWaitTime

[maks-rafalko]

Default maxWaitTime is 3000ms. When I set a delay to, for example, 5 seconds, this exception is thrown and consumer is crashed.

kafkajs-async-retry/src/index.ts

Lines 419 to 420 in 7f644a4

	// this returns control to KafkaJS while we wait for the scheduled timeout to fire
	throw new WaitBeforeProcessing(waitTime, topic, partition);

Expected behavior

Consumer continue working, delaying execution even if delay > maxWaitTime

Actual behavior

Consumer is crashed:

[Consumer] Crash: KafkaJSNonRetriableError: Waiting 4970ms before resuming processing messages from xxx-group-id-retry-1

Steps to reproduce the behavior

Just set delays more than maxWaitTime. For example delay is 5s, while default maxWaittime is 3000ms.

Additional Specs

• Node.js version 20.15.1
• Kafka version: latest
• KafkaJS version: 2.2.4