0

我最近升级到了最新的 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

我可以从官方文档中收集到的唯一信息是一些响应式消息传递包被拆分，但没有提及此连接器更改（看到我确定它没有更改）。

4

0 回答 0