KafkaReceiverProperties
class KafkaReceiverProperties(@DefaultValue(value = ["1"] ) var prefetchBatches: Int = KafkaReceiverPolicy.DEFAULT_PREFETCH_BATCHES, @DefaultValue(value = ["1"] ) var maxDeferredCommits: Int = KafkaReceiverPolicy.DEFAULT_MAX_DEFERRED_COMMITS, @DefaultValue(value = ["3"] ) var retryAttempts: Long = KafkaReceiverPolicy.DEFAULT_RETRY_ATTEMPTS, @DefaultValue(value = ["10s"] ) var retryBackoff: Duration = KafkaReceiverPolicy.DEFAULT_RETRY_BACKOFF, @DefaultValue(value = ["FAIL"] ) var decodeFailureStrategy: KafkaRecordDecodeFailureStrategy = KafkaRecordDecodeFailureStrategy.FAIL)
Constructors
Link copied to clipboard
constructor(@DefaultValue(value = ["1"] ) prefetchBatches: Int = KafkaReceiverPolicy.DEFAULT_PREFETCH_BATCHES, @DefaultValue(value = ["1"] ) maxDeferredCommits: Int = KafkaReceiverPolicy.DEFAULT_MAX_DEFERRED_COMMITS, @DefaultValue(value = ["3"] ) retryAttempts: Long = KafkaReceiverPolicy.DEFAULT_RETRY_ATTEMPTS, @DefaultValue(value = ["10s"] ) retryBackoff: Duration = KafkaReceiverPolicy.DEFAULT_RETRY_BACKOFF, @DefaultValue(value = ["FAIL"] ) decodeFailureStrategy: KafkaRecordDecodeFailureStrategy = KafkaRecordDecodeFailureStrategy.FAIL)