In your example of KafkaMaxRetryExceptionFilter you always read retry-count header but you never set it https://github.com/nestjs/docs.nestjs.com/blob/8f7a101d48b17aa8ad6c1375f68e2eb7168b64ff/content/microservices/kafka.md?plain=1#L446