private int getAttempts(ConsumerRecord<?, ?> consumerRecord) { Header header = consumerRecord.headers().lastHeader(RetryTopicHeaders.DEFAULT_HEADER_ATTEMPTS); return header != null ? header.value()[header.value().length-1] : 1; }