访问春季云流kafka事务中的重试次数

Question

我需要访问春季云流kafka事务重试中的重试次数，以便对于特定异常，基于重试次数，我可以将结果发布到不同的主题

Answer 1

我认为你指的是消费者的交付尝试；可以使用ContainerCustomizerbean将deliveryAttemptHeader属性设置为true。

/**
* Set to true to populate the
* {@link org.springframework.kafka.support.KafkaHeaders#DELIVERY_ATTEMPT} header when
* the error handler or after rollback processor implements
* {@code DeliveryAttemptAware}. There is a small overhead so this is false by
* default.
* @param deliveryAttemptHeader true to populate
* @since 2.5
*/
public void setDeliveryAttemptHeader(boolean deliveryAttemptHeader) {
this.deliveryAttemptHeader = deliveryAttemptHeader;
}

然后使用整个Message<?>来检查报头。