NestJS Kafka Consumer Retry

Hello,

I am trying to understand the consumer retry behaviour with NestJS, which uses KafkaJS under the hood. If a consumed message is retried, does it use KafkaJS retry behaviour?

If the retry exceeds the configured consumer sessionTimeout, is the consumer removed from the consumer group, a consumer group rebalance triggered, and the message redelivered? (Resulting in potential duplicate message processing).

Or is the message retried from the topic each time, potentially resulting in a poison pill (being redelivered forever and blocking the topic) if it fails for the same reason each time?

Thanks,
Rob.