Pipe
data class PipeSourceParametersManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: String? = null, val topicName: String)
Constructors
Link copied to clipboard
fun PipeSourceParametersManagedStreamingKafkaParameters(batchSize: Int? = null, consumerGroupId: String? = null, credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null, maximumBatchingWindowInSeconds: Int? = null, startingPosition: String? = null, topicName: String)