KafkaSchedulerOptions
Durable scheduler topic names and topology settings for Kafka delayed delivery.
Properties
Section titled “Properties”autoCreateTopology?
Section titled “autoCreateTopology?”
optionalautoCreateTopology?:boolean
Create scheduler topics automatically before first publish or subscribe. Defaults to true.
consumerGroup?
Section titled “consumerGroup?”
optionalconsumerGroup?:string
Scheduler consumer group. Defaults to a stable group derived from schedulesTopic.
deliveryConcurrency?
Section titled “deliveryConcurrency?”
optionaldeliveryConcurrency?:number
Maximum number of due schedules delivered at once. Defaults to 16.
deliveryRetryDelayMs?
Section titled “deliveryRetryDelayMs?”
optionaldeliveryRetryDelayMs?:number
In-process retry delay after a scheduler delivery failure in milliseconds. Defaults to 1000.
historyRetentionMs?
Section titled “historyRetentionMs?”
optionalhistoryRetentionMs?:number
Retention for the scheduler history topic in milliseconds. Uses broker defaults when unset.
historyTopic
Section titled “historyTopic”historyTopic:
string
Append-only schedule history topic.
partitions?
Section titled “partitions?”
optionalpartitions?:number
Number of partitions for scheduler topics. Defaults to 1.
replicationFactor?
Section titled “replicationFactor?”
optionalreplicationFactor?:number
Replication factor for scheduler topics. Defaults to 1.
schedulesTopic
Section titled “schedulesTopic”schedulesTopic:
string
Compacted schedule state topic.