mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2025-09-19 01:30:23 +02:00
Code Issues Projects Releases Wiki Activity
seaweedfs/weed/mq/kafka/consumer
History
Exact
chrislu b30834cc95 kafka: fix deadlock issues in static membership tests 
- Fix deadlock in FindStaticMember by adding FindStaticMemberLocked version
- Fix deadlock in RegisterStaticMember by adding RegisterStaticMemberLocked version
- Fix deadlock in UnregisterStaticMember by adding UnregisterStaticMemberLocked version
- Fix GroupInstanceID parsing in parseLeaveGroupRequest method
- All static membership tests now pass without deadlocks:
  - JoinGroup static membership (join, reconnection, dynamic members)
  - LeaveGroup static membership (leave, wrong instance ID validation)
  - DescribeGroups static membership

The deadlocks occurred because protocol handlers were calling GroupCoordinator
methods that tried to acquire locks on groups that were already locked by the
calling handler. The fix introduces *Locked versions of these methods that
assume the group is already locked by the caller.
2025-09-15 21:42:32 -07:00
..
assignment.go Implement incremental cooperative rebalancing protocol 2025-09-15 21:14:37 -07:00
assignment_test.go mq(kafka): Phase 3 Step 1 - Consumer Group Foundation 2025-09-10 13:34:28 -07:00
cooperative_sticky_test.go Phase 2 Part 1: Consumer group robustness improvements 2025-09-15 20:55:45 -07:00
group_coordinator.go kafka: fix deadlock issues in static membership tests 2025-09-15 21:42:32 -07:00
group_coordinator_test.go fmt 2025-09-12 21:34:18 -07:00
incremental_rebalancing.go Implement incremental cooperative rebalancing protocol 2025-09-15 21:14:37 -07:00
incremental_rebalancing_test.go Implement incremental cooperative rebalancing protocol 2025-09-15 21:14:37 -07:00
rebalance_timeout.go Phase 2 Part 1: Consumer group robustness improvements 2025-09-15 20:55:45 -07:00
rebalance_timeout_test.go Phase 2 Part 1: Consumer group robustness improvements 2025-09-15 20:55:45 -07:00
static_membership_test.go Implement static membership support (group.instance.id) 2025-09-15 21:10:43 -07:00