问题描述:

Caused by: org.springframework.messaging.handler.annotation.support.MethodArgumentNotValidException: Could not resolve method parameter at index 1 in public void com.***.RightLotteryListener.listen(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>,org.springframework.kafka.support.Acknowledgment): 1 error(s): [Error in object ‘ack’: codes []; arguments []; default message [Payload value must not be empty]]

原因分析:

通过yaml配置了kafka消费者,并且使用了@KafkaListener注解,但是在yaml文件没有添加spring.kafka.listener的相关配置,只配置了spring.kafka.consumer

解决方案:

在yaml中添加spring.kafka.listener的相关配置。

空气刘海

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐