Bulker: support multi-partition retry topics#1348

Merged

absorbb merged 8 commits into

retry-consumer-multi-partition

Jun 5, 2026

Commits on Jun 5, 2026

Bulker: support multi-partition retry topics

absorbb
and
claude
committed
Retry consumer: tolerate multi-partition assignment, randomize start delay

absorbb
and
claude
committed
Topic manager: report SystemError when retry topic has more partitions than shards

absorbb
and
claude
committed
fix(bulker): fix
absorbb
committed
Revert multi-partition assignment tolerance: skip topic with too many partitions instead

absorbb
and
claude
committed
Retry consumer: exit assignment wait loop as soon as assignment is valid

absorbb
and
claude
committed
Retry consumer: poll while waiting for assignment

absorbb
and
claude
committed
Topic manager: shard the shared retry topic consumer by partitions count

absorbb
and
claude
committed