stanislavkozlovski commented on code in PR #19336:
URL: https://github.com/apache/kafka/pull/19336#discussion_r2025277702
##########
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java:
##########
@@ -195,7 +195,10 @@ public class ConsumerConfig extends AbstractConfig {
"Records are fetched in batches by the consumer, and if the first
record batch in the first non-empty partition of the fetch is larger than " +
"this value, the record batch will still be returned to ensure
that the consumer can make progress. As such, this is not a absolute maximum. "
+
"The maximum record batch size accepted by the broker is defined
via <code>message.max.bytes</code> (broker config) or " +
- "<code>max.message.bytes</code> (topic config). Note that the
consumer performs multiple fetches in parallel.";
+ "<code>max.message.bytes</code> (topic config). A fetch request
consists of many partitions, and there is another setting that controls how
much " +
+ "data is returned for each partition in a fetch request - see
<code>max.partition.fetch.bytes</code>. Note that there is a current limitation
when " +
+ "performing remote reads from tiered storage (KIP-405) - only one
partition out of the fetch request is fetched from the remote store
(KAFKA-14915). " +
+ "Note also that the consumer performs multiple fetches in
parallel.";
Review Comment:
I assume it means a single consumer will send multiple fetch requests. Note
@kamalcph I didn't add this - it was here
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
