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)
