pulumi-aws-native-kotlin/com.pulumi.awsnative.pipes.kotlin.inputs/PipeSourceManagedStreamingKafkaParametersArgs

PipeSourceManagedStreamingKafkaParametersArgs

data class PipeSourceManagedStreamingKafkaParametersArgs(val batchSize: Output<Int>? = null, val consumerGroupId: Output<String>? = null, val credentials: Output<Either<PipeMskAccessCredentials0PropertiesArgs, PipeMskAccessCredentials1PropertiesArgs>>? = null, val maximumBatchingWindowInSeconds: Output<Int>? = null, val startingPosition: Output<PipeMskStartPosition>? = null, val topicName: Output<String>) : ConvertibleToJava<PipeSourceManagedStreamingKafkaParametersArgs>

Constructors

constructor(batchSize: Output<Int>? = null, consumerGroupId: Output<String>? = null, credentials: Output<Either<PipeMskAccessCredentials0PropertiesArgs, PipeMskAccessCredentials1PropertiesArgs>>? = null, maximumBatchingWindowInSeconds: Output<Int>? = null, startingPosition: Output<PipeMskStartPosition>? = null, topicName: Output<String>)

Properties

Link copied to clipboard
val batchSize: Output<Int>? = null

The maximum number of records to include in each batch.

Link copied to clipboard
val consumerGroupId: Output<String>? = null

The name of the destination queue to consume.

Link copied to clipboard
val credentials: Output<Either<PipeMskAccessCredentials0PropertiesArgs, PipeMskAccessCredentials1PropertiesArgs>>? = null

The credentials needed to access the resource.

Link copied to clipboard
val maximumBatchingWindowInSeconds: Output<Int>? = null

The maximum length of a time to wait for events.

Link copied to clipboard
val startingPosition: Output<PipeMskStartPosition>? = null

The position in a stream from which to start reading.

Link copied to clipboard
val topicName: Output<String>

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

Functions

Link copied to clipboard
open override fun toJava(): PipeSourceManagedStreamingKafkaParametersArgs