我们使用 Quarkus 来消费来自 Kafka 的事件,执行一些丰富操作,并使用自定义连接器通过 HTTP 将它们推送到内部系统。
我们需要在分派丰富的事件之前验证它们是否符合给定的模式, 并将无效事件发送到 DLQ。
我们尝试使用拦截器执行验证,但找不到一种方法以这种方式优雅地失败消息。
这可能吗? 或者是否有另一种推荐的方法来处理这种验证?
根据文档,当您在方法中抛出异常时,该消息应该被取消,而当您返回 null 时,该消息应该被跳过。
我不确定这是否也适用于拦截器。
另请参阅本节。