Java教程

spring boot集成kafka报错

本文主要是介绍spring boot集成kafka报错,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

背景:

spring boot 2.1.0 集成 kafka,报错:[org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor]: Constructor threw exception; nested exception

 

kafka依赖配置如下:

        <!-- kafka 依赖 开始 -->
        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
        </dependency>

        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.8.0</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- kafka 依赖 结束 -->

 

从这篇文章https://blog.csdn.net/littlehaes/article/details/104590423得到启发,这篇文章是把spring boot进行了版本降级,但是因为要使用kafka的NewTopic特性,版本降级就不可行了,因此选择把spring-boot-starter-parent由2.1.0升级为2.5.0,启动项目不再报错。

这篇关于spring boot集成kafka报错的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!