pulumi-aws-kotlin/com.pulumi.aws.pipes.kotlin.inputs/PipeSourceParametersSelfManagedKafkaParametersArgs

PipeSourceParametersSelfManagedKafkaParametersArgs

data class PipeSourceParametersSelfManagedKafkaParametersArgs(val additionalBootstrapServers: Output<List<String>>? = null, val batchSize: Output<Int>? = null, val consumerGroupId: Output<String>? = null, val credentials: Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs>? = null, val maximumBatchingWindowInSeconds: Output<Int>? = null, val serverRootCaCertificate: Output<String>? = null, val startingPosition: Output<String>? = null, val topicName: Output<String>, val vpc: Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs>? = null) : ConvertibleToJava<PipeSourceParametersSelfManagedKafkaParametersArgs>

Constructors

fun PipeSourceParametersSelfManagedKafkaParametersArgs(additionalBootstrapServers: Output<List<String>>? = null, batchSize: Output<Int>? = null, consumerGroupId: Output<String>? = null, credentials: Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs>? = null, maximumBatchingWindowInSeconds: Output<Int>? = null, serverRootCaCertificate: Output<String>? = null, startingPosition: Output<String>? = null, topicName: Output<String>, vpc: Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs>? = null)

Functions

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

Properties

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

An array of server URLs. Maximum number of 2 items, each of maximum length 300.

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

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

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

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

Link copied to clipboard
val credentials: Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs>? = null

The credentials needed to access the resource. Detailed below.

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

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

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

The ARN of the Secrets Manager secret used for certification.

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

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

Link copied to clipboard
val topicName: Output<String>

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

Link copied to clipboard
val vpc: Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs>? = null

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used. Detailed below.