Quarkus 3.2.6中测试Smallrye Kafka Consumer时出现异常行为

针对你在Quarkus 3.2.6中遇到的SmallRye Kafka Consumer单元测试问题，结合你的实现细节，以下是具体的排查方向和解决方法：

1. 解决InterruptedException引发的ArcUndeclaredThrowableException #

这个问题通常是测试线程提前终止，导致ManagedExecutor中正在执行的异步任务被中断。因为@Blocking(ordered=false)会将消息处理任务提交到Quarkus的ManagedExecutor线程池，而单元测试默认会在测试方法执行完毕后立即结束，不会等待异步任务完成。

解决方法：

• 在测试类中添加CountDownLatch，每处理一条消息就调用countDown()，测试方法最后调用latch.await()等待所有任务完成。
• 调整测试超时时间，确保异步任务有足够的执行周期，比如在测试方法上添加@Timeout(value = 10, unit = TimeUnit.SECONDS)。
• 配置ManagedExecutor的线程池参数，确保测试环境有足够的线程处理并行任务，在application-test.properties中添加：

  quarkus.thread-pool.core-threads=4
  quarkus.thread-pool.max-threads=8
  

2. 解决RestClientsConfig相关的NullPointerException #

使用Mockito的@InjectMock直接替换RestClient时，会跳过Quarkus CDI上下文对RestClient的初始化流程，导致依赖的RestClientsConfig等配置Bean未被正确注入。

解决方法：

• 改用Quarkus原生的@Mock注解替代@InjectMock，让Mock实例纳入CDI上下文管理，自动处理配置依赖：

  @Mock
  @RestClient
  private YourRestClient mockRestClient;
  

3. 解决随机出现的Rest Client已关闭错误 #

这个问题的核心是异步任务执行时，RestClient实例已被CDI容器销毁。测试方法执行完毕后，Quarkus会快速销毁CDI Bean，而ManagedExecutor中的异步任务可能还在运行，此时调用已被销毁的RestClient就会报错。

解决方法：

• 确保测试结束前所有异步任务都已完成，结合前面提到的CountDownLatch或等待机制，避免容器提前销毁Bean。
• 在测试类中使用@QuarkusTest注解（而非普通JUnit测试），QuarkusTest会更合理地管理测试期间的Bean生命周期。
• 若使用WireMock，确保WireMock服务器在所有异步任务执行完毕后再关闭，不要在测试方法结束时立即停止服务。

额外注意事项 #

• 手动ack的线程安全性：确保Ack实例在异步线程中调用时是有效的，避免因上下文丢失导致的ack失败。可以将Ack实例作为参数传递给异步任务，不要依赖CDI注入的上下文Bean。
• In-Memory Kafka Connector的配置：确保测试环境中Kafka消费者的配置正确，比如关闭Dev Services避免冲突：

  quarkus.kafka.devservices.enabled=false
  quarkus.kafka.consumer.bootstrap.servers=localhost:9092 # 对应In-Memory Connector的地址
  

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