最新的 Quarkus 版本 (2.6.3) 反应消息错误

Newest Quarkus version (2.6.3) reactive messaging error

我最近升级到最新的 Quarkus 版本,似乎在配置 Smallrye 的反应消息时遇到了一些问题。在 2.6.3 之前,连接器一直是 smallrye-kafka,但是当我 运行 我的应用程序无法识别时,我现在似乎遇到了一个奇怪的错误作为已知的 Kafka 连接器?

错误:

[error]: Build step io.quarkus.arc.deployment.ArcProcessor#generateResources threw an exception: javax.enterprise.inject.spi.DeploymentException: Found 2 deployment problems: 
[1] The channel 'kafka-data' is configured with an unknown connector (smallrye-kafka)
[2] The channel 'dlq-data' is configured with an unknown connector (smallrye-kafka)

这是我的配置(出于演示目的省略了实际值):

mp:
  messaging:
    incoming:
      dlq-data:
        health-topic-verification-enabled: true
        connector: smallrye-kafka
        topic: ${kafka.topic.dlq}
        failure-strategy: ignore
        broadcast: true
        value:
          deserializer: myOwnCustomDeserializer
        auto:
          offset:
            reset: earliest
        enable:
          auto:
            commit: false
        group:
          id: someGroupID
      kafka-data:
        health-topic-verification-enabled: true
        connector: smallrye-kafka
        topic: ${kafka.topic.fulfillment}
        failure-strategy: dead-letter-queue
        dead-letter-queue:
          topic: ${kafka.topic.dlq}
          value:
            serializer: io.quarkus.kafka.client.serialization.ObjectMapperSerializer
        broadcast: true
        value:
          deserializer: myOwnCustomDeserializer
        auto:
          offset:
            reset: earliest
        enable:
          auto:
            commit: false
        group:
          id: someGroupId

我唯一能从官方文档中收集到的是一些反应消息包被拆分但是没有提到这个连接器改变(看到我确定它没有改变)。

如评论中所述,请确保您在类路径中具有要使用的连接器。如果您使用的是 Quarkus,则有连接器的“扩展”。

对于 Kafka,使用:

   <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
   </dependency>