pulumi-aws-native-kotlin/com.pulumi.awsnative.pipes.kotlin.outputs/PipeSourceManagedStreamingKafkaParameters

PipeSourceManagedStreamingKafkaParameters

data class PipeSourceManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: PipeMskStartPosition? = null, val topicName: String)

Constructors

constructor(batchSize: Int? = null, consumerGroupId: String? = null, credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, maximumBatchingWindowInSeconds: Int? = null, startingPosition: PipeMskStartPosition? = 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.

Link copied to clipboard
val consumerGroupId: String? = null

The name of the destination queue to consume.

Link copied to clipboard
val credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null

The credentials needed to access the resource.

Link copied to clipboard
val maximumBatchingWindowInSeconds: Int? = null

The maximum length of a time to wait for events.

Link copied to clipboard
val startingPosition: PipeMskStartPosition? = null

The position in a stream from which to start reading.

Link copied to clipboard
val topicName: String

The name of the topic that the pipe will read from.