Skip to main content
Version: 4.0.0-incubating

Dist Worker

DistWorker handles subscription routing and fan-out (read-heavy). It runs as a stateful service on the base-kv overlay cluster; store_name for API headers: dist.worker.

Default balancers

balancerFactory FQNRoleDefault parameters (load rules)
org.apache.bifromq.dist.worker.balance.RangeLeaderBalancerFactorySpread range leaders evenly
org.apache.bifromq.dist.worker.balance.ReplicaCntBalancerFactoryKeep replica count per range to targets- votersPerRange: 3
- learnersPerRange: -1

These defaults come from distWorkerConfig.balanceConfig.balancers in starter config.