Kafka 作为一个分布式发布订阅的消息系统,是目前最流行的消息队列之一,批量消费在现实业务场景中可以提高 kafka 消费吞吐量。Spring 框架可以使用 @KafkaListener
注解来实现消费端批量消费的功能。
以下 Demo 基于 SpringBoot 2.1.1,spring-kafka-2.3
引入依赖
1 | <dependency> |
配置 yml 文件
1 | spring: |
Kafka 配置类
1 | package com.leaface.test.kafka.config; |
Consumer 端
1 | /** |