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