访问传递尝试
要访问阻塞和非阻塞传送尝试，请将这些标头添加到您的方法签名中：@KafkaListener
@Header(KafkaHeaders.DELIVERY_ATTEMPT) int blockingAttempts,
@Header(name = RetryTopicHeaders.DEFAULT_HEADER_ATTEMPTS, required = false) Integer nonBlockingAttempts仅当将 的 deliveryAttemptHeader 设置为 时，才会提供阻止投放尝试。ContainerPropertiestrue
请注意，非阻塞尝试将用于初始投放。null
从版本 3.0.10 开始，提供了一个方便的工具，允许更轻松地访问这些 headers;该访问器可以作为 listener 方法的参数提供：KafkaMessageHeaderAccessor
@RetryableTopic(backoff = @Backoff(...))
@KafkaListener(id = "dh1", topics = "dh1")
void listen(Thing thing, KafkaMessageHeaderAccessor accessor) {
...
}
使用 和 获取值。
如果未启用阻塞重试，则访问器将引发一个对于非阻塞重试，访问器返回初始传递。accessor.getBlockingRetryDeliveryAttempt()accessor.getNonBlockingRetryDeliveryAttempt()IllegalStateException1