问题描述:

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

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐