Spring-Kafka：找不到 RecordIntercepter 类

Question

我正在使用 spring boot 2.1.5 和 spring-kafka，版本未指定。项目是 gradle 6.0, java 1.8

我收到了这个错误

error creating bean with name 'org.springframework.boot.autoconfigure.kafka.kafkaannotationdrivenconfiguration': unexpected exception during bean creation; nested exception is java.lang.typenotpresentexception: type org.springframework.kafka.listener.recordinterceptor not present

这可能是什么原因造成的？请帮忙。

Answer 1

2.1.5 快一岁了；当前的 Boot 2.1.x 版本是 2.1.13。

2.1.5 使用 spring-kafka 2.2.6，所以根据你的描述，我看不出你是如何得到这个错误的。

RecordInterceptor 在 spring-kafka 2.2.7 中添加。

它是added to the Spring Boot autoconfiguration in 2.2.0。

所以你所描述的毫无意义；您必须使用 Boot 2.2.x 和旧的 spring-kafka 版本。

您的 Boot/Kafka 版本不匹配。

升级到 Boot 2.1.13（或者最好是 2.2.6）。