Skip to content

fix(router): close Kafka consumer client when subscription ends - #3133

Open
mwisner wants to merge 3 commits into
wundergraph:mainfrom
mwisner:mwisner/fix/kafka-consumer-client-leak
Open

fix(router): close Kafka consumer client when subscription ends#3133
mwisner wants to merge 3 commits into
wundergraph:mainfrom
mwisner:mwisner/fix/kafka-consumer-client-leak

refactor(router): drive Kafka poller with a merged context

fd6fdb2
Select commit
Loading
Failed to load commit list.
Codecov / codecov/project succeeded Aug 6, 2026 in 1s

54.58% (target 30.00%)

View this Pull Request on Codecov

54.58% (target 30.00%)

Details

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 54.58%. Comparing base (7a68887) to head (fd6fdb2).
⚠️ Report is 5 commits behind head on main.

Additional details and impacted files
@@             Coverage Diff             @@
##             main    #3133       +/-   ##
===========================================
+ Coverage   48.94%   54.58%    +5.63%     
===========================================
  Files        1130      247      -883     
  Lines      157571    30493   -127078     
  Branches    10883        0    -10883     
===========================================
- Hits        77130    16644    -60486     
+ Misses      78588    12242    -66346     
+ Partials     1853     1607      -246     
Files with missing lines Coverage Δ
router/pkg/pubsub/kafka/adapter.go 65.67% <100.00%> (-0.83%) ⬇️

... and 1006 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
  • 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.