Skip to content

ConsumerConfig

Defined in: packages/core/src/capture/consumer/types.ts:51

Consumer tuning.

optional backoffMs?: number

Defined in: packages/core/src/capture/consumer/retry.ts:22

Base delay of the exponential backoff in ms (default DEFAULT_BACKOFF_MS).

RetryConfig.backoffMs


optional concurrency?: number

Defined in: packages/core/src/capture/consumer/types.ts:53

Jobs run at once; default sized from the CPU and memory the process can use.


optional maxRetries?: number

Defined in: packages/core/src/capture/consumer/retry.ts:20

Retries after the first attempt (default DEFAULT_MAX_RETRIES).

RetryConfig.maxRetries


optional waitTimeSeconds?: number

Defined in: packages/core/src/capture/consumer/types.ts:55

Long-poll wait for queues that block inside poll (default 20, max 20).