[ 
https://issues.apache.org/jira/browse/KAFKA-15063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Omnia Ibrahim updated KAFKA-15063:
----------------------------------
    Description: 
{color:#172b4d}Ticket to track KIP-936. Since KIP-679 idempotent{color} 
{color:#172b4d}producers became the default in Kafka as a result of this all 
producer instances will be assigned PID. The increase of the number of PIDs 
stored in Kafka brokers by {color}{{ProducerStateManager}}{color:#172b4d} 
exposes the broker to OOM errors if it has a high number of producers, a rogue 
or misconfigured client(s).{color}

{color:#172b4d}The broker is still exposed to OOM{color} even after KIP-854 
introduced a separate config to expire PID from transaction IDs if there is a 
high number of PID before {{producer.id.expiration.ms}} is exceeded.

As a result of this, the broker will keep experiencing OOM and become offline. 
The only way to recover from this is to increase the heap.  

 

{color:#172b4d}KIP-936 is proposing throttling the number of PIDs per 
KafkaPrincipal {color}

{color:#172b4d}See the KIP-936 details here  
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-936%3A+Throttle+number+of+active+PIDs]
 {color}

  was:
{color:#172b4d}Ticket to track KIP-936. Since KIP-679 idempotent{color} 
{color:#172b4d}producers became the default in Kafka as a result of this all 
producer instances will be assigned PID. The increase of the number of PIDs 
stored in Kafka brokers by {color}{{ProducerStateManager}}{color:#172b4d} 
exposes the broker to OOM errors if it has a high number of producers, a rogue 
or misconfigured client(s).{color}

{color:#172b4d}The broker is still exposed to OOM{color} even after KIP-854 
introduced a separate config to expire PID from transaction IDs if there is a 
high number of PID before {{producer.id.expiration.ms}} is exceeded. 

As a result of this, the broker will keep experiencing OOM and become offline. 
The only way to recover from this is to increase the heap.  

 

{color:#172b4d}KIP-936 is proposing throttling the number of PIDs per 
KafkaPrincipal {color}

{color:#172b4d}See the KIP details here  
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-936%3A+Throttle+number+of+active+PIDs]
 {color}


> Throttle number of active PIDs
> ------------------------------
>
>                 Key: KAFKA-15063
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15063
>             Project: Kafka
>          Issue Type: New Feature
>          Components: core, producer 
>    Affects Versions: 2.8.0, 3.1.0, 3.0.0, 3.2.0, 3.3, 3.4.0
>            Reporter: Omnia Ibrahim
>            Priority: Major
>
> {color:#172b4d}Ticket to track KIP-936. Since KIP-679 idempotent{color} 
> {color:#172b4d}producers became the default in Kafka as a result of this all 
> producer instances will be assigned PID. The increase of the number of PIDs 
> stored in Kafka brokers by {color}{{ProducerStateManager}}{color:#172b4d} 
> exposes the broker to OOM errors if it has a high number of producers, a 
> rogue or misconfigured client(s).{color}
> {color:#172b4d}The broker is still exposed to OOM{color} even after KIP-854 
> introduced a separate config to expire PID from transaction IDs if there is a 
> high number of PID before {{producer.id.expiration.ms}} is exceeded.
> As a result of this, the broker will keep experiencing OOM and become 
> offline. The only way to recover from this is to increase the heap.  
>  
> {color:#172b4d}KIP-936 is proposing throttling the number of PIDs per 
> KafkaPrincipal {color}
> {color:#172b4d}See the KIP-936 details here  
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-936%3A+Throttle+number+of+active+PIDs]
>  {color}



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

Reply via email to