Pipe
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
Link copied to clipboard
constructor(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)
Properties
Link copied to clipboard
An array of server URLs. Maximum number of 2 items, each of maximum length 300.
Link copied to clipboard
The name of the destination queue to consume. Maximum value of 200.
Link copied to clipboard
The credentials needed to access the resource. Detailed below.
Link copied to clipboard
The maximum length of a time to wait for events. Maximum value of 300.
Link copied to clipboard
The ARN of the Secrets Manager secret used for certification.
Link copied to clipboard
The position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.
Link copied to clipboard
This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used. Detailed below.