報錯內容
在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 consumer
at 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.Deserializer
at 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
就好了
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/433335.html
標籤：其他
上一篇：大資料之Hive：space函式