You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/11/17 10:05:00 UTC

[jira] [Commented] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

    [ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787118#comment-17787118 ] 

Mickael Maison commented on KAFKA-15836:
----------------------------------------

This is marked as a blocker for 3.6.1. We're hoping the make this release in the next couple of weeks. Do you think you can provide a fix by then?

> KafkaConsumer subscribes to multiple topics does not respect max.poll.records
> -----------------------------------------------------------------------------
>
>                 Key: KAFKA-15836
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15836
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 3.6.0
>            Reporter: Philip Nee
>            Assignee: Kirk True
>            Priority: Blocker
>              Labels: consumer
>             Fix For: 3.6.1
>
>
> We discovered that when KafkaConsumer subscribes to multiple topics with max.poll.record configured.  The max.poll.record is not properly respected for all poll() invocation.
>  
> I was able to reproduce it with the AK example, here is how I ran my tests:
> [https://github.com/apache/kafka/pull/14772]
>  
> 1. start zookeeper and kafka server (or kraft mode should be fine too)
> 2. Run: examples/bin/java-producer-consumer-demo.sh 10000000
> 3. Polled records > 400 will be printed to stdout
>  
> Here is what the program does:
> The produce produces a large number of records to multiple topics.  We configure the consumer using a max.poll.record = 400, and subscribed to multiple topics.  The consumer poll, and the returned records can sometimes be larger than 400.
>  
> This is an issue in AK 3.6 but 3.5 was fine.
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)