[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418114#comment-16418114 ]
Guozhang Wang commented on KAFKA-6723: -------------------------------------- Boyang, I'm going to mark this ticket as subsumed by KAFKA-6657, and please feel free to take KAFKA-6657 as Siva does not have time to work on it lately. > Separate "max.poll.record" for restore consumer and common consumer > ------------------------------------------------------------------- > > Key: KAFKA-6723 > URL: https://issues.apache.org/jira/browse/KAFKA-6723 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Boyang Chen > Assignee: Boyang Chen > Priority: Minor > > Currently, Kafka Streams use `max.poll.record` config for both restore > consumer and normal stream consumer. In reality, they are doing different > processing workloads, and in order to speed up the restore speed, restore > consumer is supposed to have a higher throughput by setting `max.poll.record` > higher. The change involved is trivial: > [https://github.com/abbccdda/kafka/commit/cace25b74f31c8da79e93b514bcf1ed3ea9a7149] > However, this is still a public API change (introducing a new config name), > so we need a KIP. -- This message was sent by Atlassian JIRA (v7.6.3#76005)