Kafka
constructor(pollInterval: Duration = Duration.ofSeconds(DEFAULT_POLL_INTERVAL_SECONDS), batchSize: Int = DEFAULT_BATCH_SIZE, maxRetries: Int = DEFAULT_MAX_RETRIES, retryCooldown: Duration = Duration.ofMinutes(DEFAULT_RETRY_COOLDOWN_MINUTES), stuckThreshold: Duration = Duration.ofMinutes(DEFAULT_STUCK_THRESHOLD_MINUTES))(source)