Quarkus响应式代码中消息NACK导致就绪检查失败问题咨询

1. 响应式死信队列场景是否受支持？ #

Quarkus的Kafka扩展完全支持响应式模式下的死信队列处理，官方相关示例也覆盖了这类场景，核心功能是没问题的。

2. 健康检查异常的核心原因（非Bug，大概率是代码实现问题） #

健康检查告警通常和死信队列发送后的Uni处理逻辑有关，常见错误点包括：

• Uni未正确完成或错误未处理：如果死信发送的Uni最终处于失败状态（比如发送超时、Kafka连接异常），但代码未捕获处理该错误，会导致Kafka客户端的健康状态被标记为异常。
• 响应式逻辑混入阻塞操作：如果在Uni处理链里调用了Uni.await().indefinitely()这类阻塞方法，会阻塞事件循环，进而影响健康检查的正常执行。
• 死信客户端配置异常：死信队列的Kafka客户端配置（如bootstrap servers）和主消费客户端不一致，导致死信客户端连接失败，触发健康检查告警。

3. 修正建议 #

• 确保死信发送的Uni链完整处理所有异常：用onFailure().recoverWithItem()或onFailure().invoke()捕获错误，避免Uni处于未处理的失败状态。

  // 示例：处理死信发送失败的逻辑
  return deadLetterProducer.send(record)
      .onFailure().invoke(throwable -> {
          LOGGER.error("发送至死信队列失败", throwable);
      })
      .onFailure().recoverWithItem(sendResult -> null); // 恢复使Uni正常完成
  

• 全程保持响应式：所有Kafka交互逻辑都要基于Uni/CompletionStage，避免任何阻塞操作。
• 核对死信客户端配置：确保死信队列对应的Kafka集群可达，且quarkus.kafka.health.enabled配置为true（默认开启）。

4. 是否是Quarkus的Bug？ #

大概率不是框架Bug，更可能是代码中对Uni的处理不当，导致Kafka客户端健康状态被错误标记。如果排查完代码逻辑后仍存在问题，可以在Quarkus的GitHub仓库提交Issue反馈。

内容的提问来源于stack exchange，提问作者jesantana