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)