Repository navigation

fix kafka input partition ownership and autocommit on rebalance - #1024

Merged

DmitryRomanov merged 2 commits into

kafka-consume-fixes

Oct 14, 2026

Merged

fix kafka input partition ownership and autocommit on rebalance#1024
DmitryRomanov merged 2 commits into
masterfrom
kafka-consume-fixes

Commits on Oct 14, 2026
- fix kafka input partition ownership and autocommit on rebalance
  DmitryRomanov
  committed
  56aac0c
- use RWMutex for consumer ownership tracking
  DmitryRomanov
  committed
  58c36fc