SpringKafka2.2。2消费者只返回一条记录，而不是最大轮询记录

Question

我们正在使用Spring Kafka 2.2.2版本从Kafka中检索记录，使用@KafkaListener和Con电流tKafkaListenerContainerFactory。我们已经配置了max-pore-记录为5，但是它总是在列表中只给消费者1条记录，而不是5条记录。

虽然配置相同，但它在Spring Kafka 2.1中也能工作。4.释放。

这是我们的申请表。yml配置：

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      enable-auto-commit: false
      max-poll-records: 5
      bootstrap-servers: localhost:9092
      group-id: group_id
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: com.gap.cascade.li.data.xx.xx.CustomDeserialiser

以下是我们的ConcurrentKafkaListenerContainerFactory：

  @Bean
  public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setBatchListener(true);

    return factory;
  }

我们是否错过了任何需要为Spring Kafka 2.2.2版本完成的配置？

Answer 1

假设你有一个听众

@KafkaListener(...)
public void listen(List<...> data) {
    ...
}

设置工厂。setBatchListener（true） 应该适合您（只要有多条记录准备就绪）。

您还可以使用boot属性

spring:
  kafka:
    listener:
      type: batch

做同样的事情；避免申报自己的工厂。

如果启用调试日志记录，容器将记录轮询返回的记录数。您还可以设置fetch。最小字节数和获取。麦克斯，等等。ms影响在只有一条记录立即就绪时返回的记录数。。。

spring:
  kafka:
    consumer:
      auto-offset-reset: earliest
      enable-auto-commit: false
      properties:
        fetch.min.bytes: 10000
        fetch.max.wait.ms: 2000
    listener:
      type: batch

顺便说一句，当前的2.2. x版本是2.2.7（引导2.1.6）。