Pull request regarding to consumer metrics cleanup issue after shutdown

/kafka/pull/13125 I'd appreciate it if someone is interested in it. Feiyan Yu

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

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

Potential bug for forwarded request time cost metrics

sue: https://issues.apache.org/jira/browse/KAFKA-14032 PR: https://github.com/apache/kafka/pull/12360 <https://github.com/apache/kafka/pull/12360> I'd appreciate it if someone is interested in it. Feiyan Yu

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 <https://issues.apache.org/jira/browse/KAFKA-13772> with a pull request <https://issues.apache.org/jira/browse/KAFKA-13772> Thank you for your help and suggestions! Feiyan Yu 于2022年3月2

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

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

Re: Potential bugs in resizing kafka thread

lso elaborate in JIRA ticket? > > Also, welcome to submit a PR to it, since you've already had fix and test > ready! :) > > Thank you. > Luke > > > > On Sat, Mar 26, 2022 at 2:56 PM Feiyan Yu wrote: > > > Howdy! > > > > I found that the method of re

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