apoorvmittal10 opened a new pull request, #21081: URL: https://github.com/apache/kafka/pull/21081
The PR increases the max.poll.records config to 512 as the produced batch is of 512 records. SharePartition creates batches as per `share fetch` request batch-size config, which is currently controlled by max.poll.records. Drfault max.poll.records config is 500 and If producer generates multiple batches on log then there will be multiple batches in share partition. The throttled response in fetch is based on batch size in share partition hence subsequent throttles fetch calls can have different sizes as per the produces batches. To make sure the batch is of correct size in share partition increase the max.poll.records to 512. The same has been done in other test: https://github.com/apache/kafka/blob/a8b1fb9203133a356732bf069aa3e0dd9b1716b7/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java#L3707 but missed in the current PR test. -- 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]
