PipeSourceManagedStreamingKafkaParameters

data class PipeSourceManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: PipeMskStartPosition? = null, val topicName: String)

Constructors

fun PipeSourceManagedStreamingKafkaParameters(batchSize: Int? = null, consumerGroupId: String? = null, credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, maximumBatchingWindowInSeconds: Int? = null, startingPosition: PipeMskStartPosition? = null, topicName: String)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val batchSize: Int? = null
Link copied to clipboard
val consumerGroupId: String? = null
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard