apache-kafka - SpringCloudStream Kafka如何批量消费？

Question

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

标签： apache-kafkaapache-kafka-streamsspring-kafka

Answer 1

见https://docs.spring.io/spring-cloud-stream/docs/3.0.10.RELEASE/reference/html/spring-cloud-stream.html#_batch_consumers

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

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