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