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报错的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！