介绍
在 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);
}
}