You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "gdd sop (Jira)" <ji...@apache.org> on 2022/07/05 07:05:00 UTC

[jira] [Updated] (KAFKA-14045) Heartbeat threads cause high CPU usage after broker shut down

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

gdd sop updated KAFKA-14045:
----------------------------
    Description: 
1. shut down all brokers

2. execute top command and found out the kafka coordinator CPU usage is high

 

Here is the flame graph collectd by arthas.

 

The issues will recover after restart the brokers.

*{*}Maybe it should wait before the pollNoWakeup methods{*}*

[https://github.com/apache/kafka/blob/2.8/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L1372]

  was:
1. shut down all brokers

2. execute top command and found out the kafka coordinator CPU usage is high

 

Here is the flame graph collectd by arthas.

![](blob:https://issues.apache.org/b9da8430-d4e4-46c4-a9a1-655b0282950e)

The issues will recover after restart the brokers.

**Maybe it should wait before the pollNoWakeup methods**

https://github.com/apache/kafka/blob/2.8/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L1372


> Heartbeat threads  cause high CPU usage after broker shut down
> --------------------------------------------------------------
>
>                 Key: KAFKA-14045
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14045
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: gdd sop
>            Priority: Major
>
> 1. shut down all brokers
> 2. execute top command and found out the kafka coordinator CPU usage is high
>  
> Here is the flame graph collectd by arthas.
>  
> The issues will recover after restart the brokers.
> *{*}Maybe it should wait before the pollNoWakeup methods{*}*
> [https://github.com/apache/kafka/blob/2.8/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L1372]



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