Re: Potential bugs in resizing kafka thread

I fixed some ambiguous expression in the output of unit test, and also open a bug in JIRA with a pull request Thank you for your help and suggestions! Feiyan Yu 于2022年3月26日周六 16:18写道： > Than

Re: Potential bugs in resizing kafka thread

Thank you, I will make it an issue. Luke Chen 于2022年3月26日周六 16:03写道： > Hi Feiyan, > > It did look like a bug. Could you open a bug in JIRA here > < > https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-13735?filter=allopenissues > > > ? > One thing I don't fully understand from the unit t

Re: Potential bugs in resizing kafka thread

Hi Feiyan, It did look like a bug. Could you open a bug in JIRA here ? One thing I don't fully understand from the unit test is that, you have output "error distributions: $tpsWithoutResize". I thought the bug

Potential bugs in resizing kafka thread

Howdy! I found that the method of resizing fetching thread had one potential bug which lead to imbalanced partitions distribution for each thread after changing thread number on dynamic configuration. To figure it out, I added a primitive unit test method "testResize" in "AbstractFetcherThreadTes