如何使用Spring Boot等待完整的Kafka消息批？

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "your_topic_name")
    public void consume(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

@Configuration
public class KafkaConfig {

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(consumerConfigs()));
        factory.setBatchListener(true); // 启用批量消费
        return factory;
    }

    // 配置Kafka消费者的相关属性
    // ...

}

@KafkaListener(topics = "your_topic_name")
public void consume(List<String> messages) {
    // 处理接收到的消息批
    for (String message : messages) {
        System.out.println("Received message: " + message);
    }
}