@@KafkaHandler上的有效@Payload–bug或缺少功能？

Question

我们将Spring Kafka与Spring Boot（所有最新版本）结合使用。我们将Kafka消息的处理转换为KafkaHandler注释方法，并期望有效的验证方法和有效的有效载荷能够确保有效载荷的验证，但事实并非如此。此功能适用于KafkaListener，是否也适用于KafkaHandler？

@KafkaListener(...)
@Component
public class NotificationListener {

    @KafkaHandler
    public void handleV1(@Payload @Valid NotificationV1 notification) {

非常感谢。

Answer 1

KafkaListener与Valid注释一起工作的原因是，它就像restful控制器endpoint一样，是服务的入口。该团队致力于为这些情况下的验证工作添加支持，可以发现该验证机制是在2018年添加的。

至于@KafkaHandler，我对spring-kafka不太熟悉，但如果验证不起作用，那只是意味着团队不添加对这种情况的支持。我建议您使用Spring Boot方法验证功能，它适用于所有Spring托管bean和所有标准验证注释，例如@size。最后一件事，小心验证失败时抛出的异常。

Answer 2

在这种情况下不应用Validator，因为我们只是没有为此目的访问PayloadMesodArgumentResolver。

多方法@KafkaListener的目标有效负载在我们调用该方法之前被解析，因为我们肯定需要知道要调用哪个方法。这样的逻辑在InvocableHandlerM中完成ethod.get方法（）：

        args[i] = findProvidedArgument(parameter, providedArgs);
        if (args[i] != null) {
            continue;
        }
        ...
        try {
            args[i] = this.resolvers.resolveArgument(parameter, message);
        }

验证程序功能是在那些解析程序中完成的。findProvidedArgument（）为我们提供了之前为执行而转换的负载，这里我们只是不检查参数上的任何注释。

当我们选择了一个处理程序并且在调用它之前，我们可能需要将验证逻辑轮询到DelegatingInvokableHandler中。。。

请随时提出GitHub问题，这样我们就不会忘记这需要以某种方式加以解决。