You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Jan 24, 2024. It is now read-only.
Is your feature request related to a problem? Please describe.
When I revisited the GroupMetadataManager related code, I found the code is not consistent with the latest Kafka implementation since it was written in a very early time.
Describe the solution you'd like
Follow the Kafka 3.0 source code to refactor the GroupMetadataManager to manage these two most important fields correctly:
/* partitions of consumer groups that are being loaded, its lock should be always called BEFORE the group lock if needed */privatevalloadingPartitions: mutable.Set[Int] = mutable.Set()
/* partitions of consumer groups that are assigned, using the same loading partition lock */privatevalownedPartitions: mutable.Set[Int] = mutable.Set()
Is your feature request related to a problem? Please describe.
When I revisited the
GroupMetadataManagerrelated code, I found the code is not consistent with the latest Kafka implementation since it was written in a very early time.Describe the solution you'd like
Follow the Kafka 3.0 source code to refactor the
GroupMetadataManagerto manage these two most important fields correctly: