问题描述
kafka在yml文件中未开启批量消费时,程序正常运行;但一开启正常消费后,就直接报错;排查问题的过程中一直觉得是配置文件里的问题,最后发现是消费者接受的参数类型错误
问题本质
消费者开启批量消费数据后,不能用单个实体类接收参数,而应该用list
解决方法
修改消费者函数参数类型
标签:invoked,incoming,springframework,kafka,Listener,message,method From: https://www.cnblogs.com/ReturnOfTheKing/p/17961056