shared-infrastructure/com.vertyll.veds.sharedinfrastructure.kafka/KafkaOutboxProperties

KafkaOutboxProperties

@ConfigurationProperties(prefix = "veds.outbox")

data class KafkaOutboxProperties(val pollInterval: Duration = Duration.ofSeconds(DEFAULT_POLL_INTERVAL_SECONDS), val batchSize: Int = DEFAULT_BATCH_SIZE, val maxRetries: Int = DEFAULT_MAX_RETRIES, val retryCooldown: Duration = Duration.ofMinutes(DEFAULT_RETRY_COOLDOWN_MINUTES), val stuckThreshold: Duration = Duration.ofMinutes(DEFAULT_STUCK_THRESHOLD_MINUTES))(source)

Externalized configuration for the Kafka transactional outbox.

Bound from veds.outbox.* and consumed by KafkaOutboxProcessor. All values have sane defaults so the outbox works out-of-the-box without any configuration.

Example:

veds:
  outbox:
    poll-interval: 5s
    batch-size: 100
    max-retries: 5
    retry-cooldown: 1m
    stuck-threshold: 5m

Constructors

KafkaOutboxProperties

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))