[
https://issues.apache.org/jira/browse/KAFKA-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18060120#comment-18060120
]
PoAn Yang commented on KAFKA-17967:
-----------------------------------
KIP-1269: [https://cwiki.apache.org/confluence/x/loI8G]
Discussion thread:
[https://lists.apache.org/thread/vkoqpq10xmvvzknfn65r394d577yogrk]
> Dynamic change ProducerStateEntry#NUM_BATCHES_TO_RETAIN based on
> max.in.flight.requests.per.connection
> ------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-17967
> URL: https://issues.apache.org/jira/browse/KAFKA-17967
> Project: Kafka
> Issue Type: Improvement
> Reporter: PoAn Yang
> Assignee: PoAn Yang
> Priority: Major
>
> Followup from
> https://issues.apache.org/jira/browse/KAFKA-17926?focusedCommentId=17895138&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17895138
> In server side, by default, we set ProducerStateEntry#NUM_BATCHES_TO_RETAIN
> as 5 for each producer. In client side, the max in flight requests can be
> changed by max.in.flight.requests.per.connection. We can enhance the producer
> request to carry the max.in.flight.requests.per.connection value, allowing
> the server to initialize or adjust ProducerStateEntry with the correct size.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
