Pipe
constructor(additionalBootstrapServers: List<String>? = null, batchSize: Int? = null, consumerGroupId: String? = null, credentials: PipeSourceParametersSelfManagedKafkaParametersCredentials? = null, maximumBatchingWindowInSeconds: Int? = null, serverRootCaCertificate: String? = null, startingPosition: String? = null, topicName: String, vpc: PipeSourceParametersSelfManagedKafkaParametersVpc? = null)