改成批量消费消息有两个需要注意的地方:
1、配置文件修改
# 批量消费每次最多消费条目数 max-poll-records: 20
listener: # 关闭监听topic不存在的话项目启动报错 missing-topics-fatal: false # 设置为批量消费 type: batch
2、消费配置
1**
* 测试批量消费消息
* 就算是批量消费,这个地方也不一定就是批量获取到消息
* @param msgList
*/
@KafkaListener(id="consumer1ForTopic01", groupId = "group01", topics = {"topic07"})
public void consumeTopic07(List msgList) {
if (msgList != null) {
System.out.println("consumer1ForTopic07-" + msgList.size());
for (OrderMsg msg : msgList) {
System.out.println(msg.toString());
}
}
} 


