Quarkus 消息传递 - 验证连接器传出消息

问题描述 投票:0回答:1

我们使用 Quarkus 来消费来自 Kafka 的事件,执行一些丰富操作,并使用自定义连接器通过 HTTP 将它们推送到内部系统。

我们需要在分派丰富的事件之前验证它们是否符合给定的模式, 并将无效事件发送到 DLQ。

我们尝试使用拦截器执行验证,但找不到一种方法以这种方式优雅地失败消息。

这可能吗? 或者是否有另一种推荐的方法来处理这种验证?

apache-kafka quarkus quarkus-reactive smallrye-reactive-messaging
1个回答
0
投票

根据文档,当您在方法中抛出异常时,该消息应该被取消,而当您返回 null 时,该消息应该被跳过。

我不确定这是否也适用于拦截器。

另请参阅本节

© www.soinside.com 2019 - 2024. All rights reserved.