Pipe
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)