一次轮询调用可以从一个分区返回多个记录吗



基于单据,https://kafka.apache.org/25/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#poll-java.time.Duration-

轮询方法返回ConsumerRecords<K、 V>其是Map<TopicPartition,列表<消费者记录<K、 V>gt>记录,所以我怀疑答案是,是的,轮询方法的一次调用可以从同一个分区返回多个记录,但我只需要确定。

我知道,当消费者在多个分区上侦听时,它肯定会返回多个记录。。。但是它是否也可以在poll((方法中从同一分区返回多个记录?

是的,它最多可以返回max.poll.records,默认为每个分区500。

最新更新