我在@KafkaListener
中使用了
记录的方法进行有效负载验证,并且它在SpringBoot-2.7和spring-kafka-2.8中工作得很好。但是升级到 SpringBoot-3.2 和 spring-kafka-3.1 后,相同的代码不再执行任何操作,并且当事件有效负载无效时,我没有收到任何抛出的异常。
LocalValidatorFactoryBean
是通过KafkaListenerConfigurer
安装的,如下所示:
@Bean
public KafkaListenerConfigurer configureKafkaListeners(LocalValidatorFactoryBean validator) {
return registrar -> registrar.setValidator(validator);
}
存在
spring-boot-starter-validation
依赖项。但验证不起作用,我不知道为什么。结果路径上还有
javax.validation:validation-api
,我还没有把所有import javax.*
都换成import jakarta.*
。