Skip to content

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

Open
DmitryRomanov wants to merge 2 commits into
masterfrom
kafka-consume-fixes
Open

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

use RWMutex for consumer ownership tracking

37bb486
Select commit
Loading
Failed to load commit list.

Select a check to view from the sidebar