SpringCloudStream Kafka如何批量消费？

【问题标题】：How does SpringCloudStream Kafka consume in bulk?SpringCloudStream Kafka如何批量消费？
【发布时间】：2020-12-17 22:52:57
【问题描述】：

原生Kafka可以使用KafkaConsumer.poll()批量获取消息。集成spring cloud starter stream Kafka（3.0.10.Release）后如何配置？没看懂官方文档希望举个例子，谢谢

【问题讨论】：

【解决方案1】：

设置batch-mode消费者绑定属性并使用

@Bean
Consumer<List<Foo>> input() {
    return list -> {
        System.out.println(list);
    };
}

【讨论】：

一旦指定了@bean，如何接收消息？@StreamListener 可以接收单条。应该如何接收该批次？
bean 就是你所需要的。（已弃用）@StreamListener 编程模型不支持批处理模式，它仅适用于新的功能模型。 docs.spring.io/spring-cloud-stream/docs/3.0.10.RELEASE/…