pulumi-aws-kotlin/com.pulumi.aws.pipes.kotlin.outputs/PipeSourceParametersManagedStreamingKafkaParameters

PipeSourceParametersManagedStreamingKafkaParameters

data class PipeSourceParametersManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: String? = null, val topicName: String)

Constructors

constructor(batchSize: Int? = null, consumerGroupId: String? = null, credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null, maximumBatchingWindowInSeconds: Int? = null, startingPosition: String? = null, topicName: String)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val batchSize: Int? = null

The maximum number of records to include in each batch. Maximum value of 10000.

Link copied to clipboard
val consumerGroupId: String? = null

The name of the destination queue to consume. Maximum value of 200.

Link copied to clipboard
val credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null

The credentials needed to access the resource. Detailed below.

Link copied to clipboard
val maximumBatchingWindowInSeconds: Int? = null

The maximum length of a time to wait for events. Maximum value of 300.

Link copied to clipboard
val startingPosition: String? = null

The position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

Link copied to clipboard
val topicName: String

The name of the topic that the pipe will read from. Maximum length of 249.