Class ZBStreamWorker

Optional jitter in milliseconds. When provided, the worker will wait a random period up to this value before polling and opening the stream. Useful for staggering multiple stream workers.

Interval in milliseconds between sidecar poll cycles. The sidecar poll is a low-frequency safety net that picks up jobs the stream may have missed (e.g. jobs re-queued after a timeout). Each poll is a command on the broker, so keep this value high to minimise load.

Defaults to 30000 (30 seconds). Set to 0 or -1 to disable recurring polling (the initial backfill poll still runs).

Maximum number of jobs to activate per poll cycle (both the initial backfill and the recurring sidecar polls). Defaults to 32.