PipeSourceParametersManagedStreamingKafkaParametersArgs

data class PipeSourceParametersManagedStreamingKafkaParametersArgs(val batchSize: Output<Int>? = null, val consumerGroupId: Output<String>? = null, val credentials: Output<PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs>? = null, val maximumBatchingWindowInSeconds: Output<Int>? = null, val startingPosition: Output<String>? = null, val topicName: Output<String>) : ConvertibleToJava<PipeSourceParametersManagedStreamingKafkaParametersArgs>

Constructors

fun PipeSourceParametersManagedStreamingKafkaParametersArgs(batchSize: Output<Int>? = null, consumerGroupId: Output<String>? = null, credentials: Output<PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs>? = null, maximumBatchingWindowInSeconds: Output<Int>? = null, startingPosition: Output<String>? = null, topicName: Output<String>)

Functions

Link copied to clipboard
open override fun toJava(): PipeSourceParametersManagedStreamingKafkaParametersArgs

Properties

Link copied to clipboard
val batchSize: Output<Int>? = null
Link copied to clipboard
val consumerGroupId: Output<String>? = null
Link copied to clipboard
val maximumBatchingWindowInSeconds: Output<Int>? = null
Link copied to clipboard
val startingPosition: Output<String>? = null
Link copied to clipboard
val topicName: Output<String>