KafkaSchedulerOptions

Durable scheduler topic names and topology settings for Kafka delayed delivery.

Properties

optional autoCreateTopology?: boolean

Create scheduler topics automatically before first publish or subscribe. Defaults to true.

optional consumerGroup?: string

Scheduler consumer group. Defaults to a stable group derived from schedulesTopic.

optional deliveryConcurrency?: number

Maximum number of due schedules delivered at once. Defaults to 16.

optional deliveryRetryDelayMs?: number

In-process retry delay after a scheduler delivery failure in milliseconds. Defaults to 1000.

optional historyRetentionMs?: number

Retention for the scheduler history topic in milliseconds. Uses broker defaults when unset.

historyTopic: string

Append-only schedule history topic.

optional partitions?: number

Number of partitions for scheduler topics. Defaults to 1.

optional replicationFactor?: number

Replication factor for scheduler topics. Defaults to 1.

schedulesTopic: string

Compacted schedule state topic.