@KafkaListener设置批处理

Apache Kafka是一个分布式流处理平台，`KafkaListener`是Spring Kafka库中的一个组件，用于从Kafka主题中消费消息。如果你想设置批处理（batching）模式，这意味着消息会被累积在一起，直到达到预设的数量或时间间隔后才发送到消费者。这样可以减少网络开销并提高性能。

在Spring Kafka中，你可以使用`@KafkaListener`注解的`messageCount`和`maxPollRecords`属性来配置批处理。`messageCount`指定每个批次中的消息数量，而`maxPollRecords`则设置了最大接收消息数，当达到这个值时，批处理完成。

例如：

@Component
public class MyConsumer {

    @KafkaListener(topics = "my-topic", groupId = "group-id", consumerFactory = MyConsumerFactory.class)
    public void consume(@Payload List<String> messages) {
        // 处理批量消息
    }

    // 这里可以设置批处理相关的属性
    @Bean
    public MessageListenerContainer myListenerContainer() {
        Map<String, Object> config = new HashMap<>();
        config.put(ConsumerConfig.BATCH_SIZE_CONFIG, 100); // 每批处理100条消息
        config.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 1000); // 最大接收1000条记录才完成一次批处理
        return new DefaultKafkaConsumerFactory<>(config, new StringDeserializer(), new StringDeserializer())
                .createConsumer();
    }
}