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

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

val batchSize: Int? = null

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

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

The credentials needed to access the resource. Detailed below.

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

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

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