[
https://issues.apache.org/jira/browse/KAFKA-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762979#comment-15762979
]
Stephane Maarek commented on KAFKA-4560:
----------------------------------------
Hi [~huxi_2b], this setting has the following description: "The maximum number
of records returned in a single call to poll()."
This doesn't affect how many records are returned in the end per partition,
just affect how many records are affected at each time of the poll call within
a loop.
As you see
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L991
isn't affected by the parameter max.partition.fetch.bytes which is probably at
a higher level wrapper call (I can't find it)
> Min / Max Partitions Fetch Records params
> -----------------------------------------
>
> Key: KAFKA-4560
> URL: https://issues.apache.org/jira/browse/KAFKA-4560
> Project: Kafka
> Issue Type: Improvement
> Components: consumer
> Affects Versions: 0.10.0.1
> Reporter: Stephane Maarek
> Labels: features, newbie
>
> There is currently a `max.partition.fetch.bytes` parameter to limit the total
> size of the fetch call (also a min).
> Sometimes I'd like to control how many records altogether I'm getting at the
> time and I'd like to see a `max.partition.fetch.records` (also a min).
> If both are specified the first condition that is met would complete the
> fetch call.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
