java - Spring kafka错误由: java. lang.ClassNotFoundException : org. springframework.kafka.transaction.KafkaAwareTransactionManager引起

标签 java spring-boot spring-kafka spring-kafka-test

这是刚刚启动的带有简单主类的 Spring Boot 项目,在没有 spring-kafka 依赖的情况下它可以正常工作,但在添加 spring-kafkaspring-kafka-test 后异常炸毁,github here

gradle.build

apply plugin: 'java-library'

repositories {
    jcenter()
 }

dependencies {

     compile group: 'org.springframework.boot', name: 'spring-boot-starter-web', version: '2.1.0.RELEASE'
     compile group: 'org.springframework.kafka', name: 'spring-kafka', version: '2.0.5.RELEASE'
    testCompile group: 'org.springframework.kafka', name: 'spring-kafka-test', version: '2.0.5.RELEASE'

 }

主类

@SpringBootApplication
public class KafkaMain {

public static void main(String[] args) {
    SpringApplication.run(KafkaMain.class, args);
     }

  }

错误

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2018-12-16 19:32:29.347 ERROR 39854 --- [           main] o.s.boot.SpringApplication               : Application run failed

org.springframework.beans.factory.BeanCreationException: Erro creating beanwithname'org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration': Unexpected exception during bean creation; nested exception is java.lang.TypeNotPresentException: Type org.springframework.kafka.transaction.KafkaAwareTransactionManager not present
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:511) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:846) ~[spring-beans-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:863) ~[spring-context-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) ~[spring-context-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140) ~[spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) [spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) [spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:316) [spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260) [spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248) [spring-boot-2.1.0.RELEASE.jar:2.1.0.RELEASE]
at com.kafka.KafkaMain.main(KafkaMain.java:10) [bin/:na]
Caused by: java.lang.TypeNotPresentException: Type org.springframework.kafka.transaction.KafkaAwareTransactionManager not present

最佳答案

Spring for Apache Kafka 2.0.x 与 Spring Boot 2.1.x 不兼容。您必须使用 Spring-Kafka 2.2.x。更重要的是,最好只依赖 Spring Boot 本身的依赖。请参阅https://start.spring.io/有关如何正确启动 Spring Boot 项目的更多信息。

如果没有被问到,请不要在不同的地方重复您的问题。

关于java - Spring kafka错误由: java. lang.ClassNotFoundException : org. springframework.kafka.transaction.KafkaAwareTransactionManager引起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53808053/

相关文章:

java - 使用 java ConcurrentHashMap 实现缓存

java - 如何用java编写elasticsearch查询聚合?

java - 由于响应内容类型无效,其余模板交换失败

java - 在 Spring Boot 应用程序中提供 HTML 页面

apache-kafka - Kafka主题中如何写KTable?就像我们在 KStreams 中使用 "to()"如何为 KTable 那样做?

java - 在replaceAll正则表达式中使用\b

java - 启动/停止媒体播放器 android studio

java - Spring引导JPA中的“ConverterNotFoundException”

apache-kafka - Spring Kafka 轮询,@KafkaListener 和监听器确认模式设置为记录

java - 这是 Spring-Kafka 文档中有关 BatchErrorHandler 的错误吗?