KlokkaSettings
constructor(queues: List<QueueConfig> = listOf(QueueConfig(QueueName.DEFAULT)), role: KlokkaRole = KlokkaRole.Both, defaultRetry: RetryPolicy = RetryPolicy.exponential(), defaultTimeout: Duration? = null, codec: PayloadCodec = JsonPayloadCodec(), clock: Clock = Clock.System, lease: Duration = 5.minutes, heartbeatInterval: Duration = 1.minutes, pollInterval: Duration = 10.seconds, claimBatch: Int = 16, retention: RetentionPolicy = RetentionPolicy(), sweepInterval: Duration = 1.hours, drainTimeout: Duration = 25.seconds, lateThreshold: Duration = 1.minutes, workerId: WorkerId = WorkerId.random())