[jira] [Created] (KAFKA-14626) Kafka Consumer Coordinator does not cleanup all metrics

[Feiyan Yu (Jira)]

Feiyan Yu created KAFKA-14626:
-

 Summary: Kafka Consumer Coordinator does not cleanup all metrics
 Key: KAFKA-14626
 URL: https://issues.apache.org/jira/browse/KAFKA-14626
 Project: Kafka
  Issue Type: Bug
Reporter: Feiyan Yu


Getting inspired by 
[KAFKA-9306|https://issues.apache.org/jira/browse/KAFKA-9306],  I found that 
there is no logic to remove metrics registered in `ConsumerCoordinatorMetrics` 
when `ConsumerCoordinator` is closed, which might 



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

[jira] [Created] (KAFKA-13772) Unevenly distribute topic partitions for threads after resizing thread number

[Feiyan Yu (Jira)]

Feiyan Yu created KAFKA-13772:
-

 Summary: Unevenly distribute topic partitions for threads after 
resizing thread number 
 Key: KAFKA-13772
 URL: https://issues.apache.org/jira/browse/KAFKA-13772
 Project: Kafka
  Issue Type: Bug
  Components: core
Affects Versions: 3.0.1, 1.1.0
Reporter: Feiyan Yu
 Fix For: 3.3.0


The method 'resizeThreadPool' is suppose to redistributed all topic partitions 
to threads based on the new thread number, and they should be distributed  
evenly. 
 
However, the resizing process which has a logic to add  fetcher to 
'fetcherThreadMap' is within the iteration of 'fetcherThreadMap' all fetchers, 
which could lead to skipping some fetchers and these fetchers remain their 
topic partition assignment.
 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)