kafka
kafka copied to clipboard
MINOR: Fix locking in GroupMetadataManager's metrics
Using group synchronized when accessing the group state does not seem to be correct because the group is protected by a lock. Instead we should use group.inLock.
Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
I can't see where's the difference between synchronized and inLock, either. Could you please explain more?