Pipe
data class PipeSourceSelfManagedKafkaParameters(val additionalBootstrapServers: List<String>? = null, val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: Any? = null, val maximumBatchingWindowInSeconds: Int? = null, val serverRootCaCertificate: String? = null, val startingPosition: PipeSelfManagedKafkaStartPosition? = null, val topicName: String, val vpc: PipeSelfManagedKafkaAccessConfigurationVpc? = null)
Constructors
Link copied to clipboard
constructor(additionalBootstrapServers: List<String>? = null, batchSize: Int? = null, consumerGroupId: String? = null, credentials: Any? = null, maximumBatchingWindowInSeconds: Int? = null, serverRootCaCertificate: String? = null, startingPosition: PipeSelfManagedKafkaStartPosition? = null, topicName: String, vpc: PipeSelfManagedKafkaAccessConfigurationVpc? = null)
Properties
Link copied to clipboard
An array of server URLs.
Link copied to clipboard
The name of the destination queue to consume.
Link copied to clipboard
The credentials needed to access the resource.
Link copied to clipboard
The maximum length of a time to wait for events.
Link copied to clipboard
Optional SecretManager ARN which stores the database credentials
Link copied to clipboard
The position in a stream from which to start reading.
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.