feat(consumer): periodically restart the Rust consumer to reconnect to Kafka#8085

Open

phacops wants to merge 9 commits into

claude/epic-bohr-dbnj39

Commits on Jun 22, 2026

feat(consumer): periodically restart the Rust consumer to reconnect to Kafka
claude
committed
fix(consumer): quantize rebalance on periodic restart
claude
committed
ref(consumer): restart the consumer loop in-process instead of exiting
claude
committed
fix(consumer): tidy restart-loop rebalance delay and timer lifecycle
claude
committed
fix(consumer): refresh rebalance delay per restart and make timer interruptible
claude
committed
fix(consumer): resolve restart/stop race and Ctrl-C lock-hold
claude
committed
fix(rebalancing): guard quantized_rebalance_delay against a zero delay
claude
committed
fix(consumer): clear shared handle after a run ends
claude
committed
Merge branch 'master' into claude/epic-bohr-dbnj39
mchen-sentry
authored