Version 3.3.2
When using blocking retries for a batch listener, the attempt number is not coming in DELIVERY_ATTEMPT header even if setting setDeliveryAttemptHeader(true)
The method KafkaMessageListenerContainer.ListenerConsumer.internalHeaders is called only in
ConsumerRecord<K, V> checkEarlyIntercept(ConsumerRecord<K, V> recordArg) which is used for a regular listener, and is not called in
ConsumerRecords<K, V> checkEarlyIntercept(ConsumerRecords<K, V> nextArg) which is used for a batch listener
Version 3.3.2
When using blocking retries for a batch listener, the attempt number is not coming in DELIVERY_ATTEMPT header even if setting
setDeliveryAttemptHeader(true)The method
KafkaMessageListenerContainer.ListenerConsumer.internalHeadersis called only inConsumerRecord<K, V> checkEarlyIntercept(ConsumerRecord<K, V> recordArg)which is used for a regular listener, and is not called inConsumerRecords<K, V> checkEarlyIntercept(ConsumerRecords<K, V> nextArg)which is used for a batch listener