目录
批量消费全局配置
单独为消费者开启批量消费配置
Kafka默认的listener消费模式为single单消息模式,即一次消费一条消息。
批量消费可以一次性消费到多条消息，如果是顺序不敏感的业务，可以另外开启线程池多线程处理这批消息，提高客户端处理效率。
- 开启批量消费后消费方法也要以List集合去接收ConsumerRecord参数才能得到批量的消息集合。
- 处理逻辑需要做好业务幂等;因为当一批消息里有个别消息处理失败，重试时需要取这批消息中出现失败的且索引最小的那条进行重试,有可能会导致中间又没处理失败的消息也被重试。
- 批量消费模式下如果使用重试功能需要在consume方法所在的线程中抛出B
