报错内容

在SpringBoot项目中使用了Kafka，在启动的过程中报错

2022-02-26 11:44:10.422 ERROR 26148 --- [           main] o.s.boot.SpringApplication               : Application run failed
org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.KafkaException: Failed to construct kafka consumerat org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:185) ~[spring-context-5.2.7.RELEASE.jar:5.2.7.RELEASE]at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:53) ~[spring-context-5.2.7.RELEASE.jar:5.2.7.RELEASE]at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:360) ~[spring-context-5.2.7.RELEASE.jar:5.2.7.RELEASE]

Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.IntegerSerializer is not an instance of org.apache.kafka.common.serialization.Deserializerat org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:372) ~[kafka-clients-2.3.1.jar:na] at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:713) ~[kafka-clients-2.3.1.jar:na]... 27 common frames omitted

原因在报错中很清晰了，消费者反序列化使用的类错误

解决方案

把spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.IntegerSerializer
改为
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.IntegerDeserializer
就好了

SpringBoot中使用Kafka报错：Failed to construct kafka consumer相关推荐

【已解决】Springboot服务 Netty启动报错Failed to submit a listener
[已解决]Springboot服务 Netty启动报错Failed to submit a listener Force-closing a channel whose registration ta ...
(错误)SpringBoot 中使用HikariPool 报错
SpringBoot在使用中发现报错,具体如下: 经过查资料是由于HikariPool 里的maxLifetime 设置不当导致的.一开始只是单纯的加大maxLifetime的链接.但是发现还不对,进 ...
kafka报错Failed to find any class that implements Connector
在使用kafka的connect的功能时候遇到报错. 完整报错如下: [2020-09-11 11:14:53,612] ERROR Failed to create job for /home/ap ...
SpringBoot中yml文件报错：org.yaml.snakeyaml.scanner.ScannerException:mapping values are not allowe here...
场景 SpringBoot中配置静态资源访问路径时提示: 报错代码如下: 实现首先确保yml文件的格式要正确,每个冒号的后面要紧跟空格. 根据提示报错信息在static-path-pattern这个 ...
【Flink】Flink 写入 kafka 报错 Failed to send data to Kafka: Expiring 4 record(s) for 20001 ms has passed
文章目录 1.场景1 1.1 概述 1.2 百度 1.3 同样问题 2.场景再现本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.场景1 1.1 概 ...
解决tomcat在pycharm中的初始化报错“ Failed to transfer file”“could not create folder”“(Permission denied)”
一.系统环境客户端:Win10 1903:IDEA Ultimate 2020.1.3: 服务器:Ubuntu20:JDK1.8:Tomcat9.0.43 二.报错现象运行Tomcat后,提示运行 ...
SpringBoot 中使用HikariPool 报错Possibly consider using a shorter maxLifetime value.
SpringBoot 使用HikariPool遇到: HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connecti ...
【Flink】flink Kafka报错 : Failed to send data to Kafka: This server is not the leader for that topic-pa
1.背景出现这个问题的背景请参考:[Kafka]Failed to send data to Kafka: Expiring 30 record(s) for xxx 732453 ms has p ...
ubuntu中打开终端报错Failed to execute default Terminal Emulator
问题描述在ubuntu中无法打开终端,提示未能执行默认终端,如下所示可能原因错误已经给出了提示,未能执行默认终端,更改默认项就可以了问题解决在settings中找到Preferred App ...
【Kafka】Flink kafka 报错 Failed to send data to Kafka: Failed to allocate memory within the config
1.背景 [2020-09-05 14:57:51] [INFO] [org.apache.flink

SpringBoot中使用Kafka报错：Failed to construct kafka consumer

报错内容

解决方案

SpringBoot中使用Kafka报错：Failed to construct kafka consumer相关推荐

最新文章

热门文章