在@KafkaListener注解中如何设置properties，让每次拉取10条

在@KafkaListener注解中，可以通过设置containerFactory属性来配置消费者容器工厂，然后在容器工厂中设置KafkaConsumer的properties，从而实现每次拉取10条消息的效果。

以下是示例代码：

@KafkaListener(topics = "mytopic", containerFactory = "kafkaListenerContainerFactory")
public void listen(List<String> messages) {
    // 处理消息
}

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setBatchListener(true); // 开启批量监听
    factory.getContainerProperties().setPollTimeout(3000); // 拉取超时时间
    factory.setConcurrency(3); // 并发消费者数量
    factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE); // 手动ack
    // 设置KafkaConsumer的properties
    Map<String, Object> props = new HashMap<>();
    props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 10);
    factory.setConsumerProperties(props);
    return factory;
}

在上面的代码中，我们创建了一个ConcurrentKafkaListenerContainerFactory，并设置了一些属性，包括：

- consumerFactory：消费者工厂
- batchListener：开启批量监听
- pollTimeout：拉取超时时间
- concurrency：并发消费者数量
- AckMode：手动ack

然后，我们通过factory.setConsumerProperties(props)方法，设置了KafkaConsumer的properties，其中ConsumerConfig.MAX_POLL_RECORDS_CONFIG属性设置为10，表示每次拉取10条消息。

这样配置后，每次从Kafka拉取消息时，会最多拉取10条消息，然后批量处理这些消息。如果消息数量少于10条，也会立即返回。