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
fun PipeSourceSelfManagedKafkaParameters(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)