介绍

在 kafka教程-springboot实现简单消费者 基础上修改

修改application.prpertise

开启批量消费

# 设置批量消费
spring.kafka.listener.type=batch
# 批量消费每次最多消费多少条消息
spring.kafka.consumer.max-poll-records=50

java代码

用List来接收消息

@KafkaListener(id = "testconsumer",groupId = "user-group", topics = "userlog")
public void onMessage3(List records) {
    System.out.println(">>>批量消费一次，records.size()="+records.size());
    for (Object data : records) {
        System.out.println(data);
    }
}