访问春云流kafka事务中的重试尝试号

Question

我需要访问spring云流kafka事务性重试中的重试尝试号，这样对于特定的异常，基于重试尝试号，我可以将结果发布到不同的主题。

Answer 1

我假设您是指消费者中的传递尝试；您可以使用ContainerCustomizer bean将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<?>来检查标头。