Chris Lu 6aa353716a test(kafka): snapshot consumer-group state mid-attempt for resumption flake ...

The onRetry hook in TestOffsetManagement/ConsumerGroupResumption only fires
after defer reader.Close(), so every dump shows the post-LeaveGroup Empty
state — useless for diagnosing why the second consumer hangs in the join
cycle. Add an onTick callback fired every 1.5s while the reader is still
joined so we can see PreparingRebalance / CompletingRebalance churn,
leader, and member assignments during the 20s attempt window.

2026-05-04 15:29:33 -07:00

..

comprehensive_test.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

offset_management_test.go

test(kafka): snapshot consumer-group state mid-attempt for resumption flake

2026-05-04 15:29:33 -07:00