Pipe
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
Link copied to clipboard
fun PipeSourceManagedStreamingKafkaParameters(batchSize: Int? = null, consumerGroupId: String? = null, credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, maximumBatchingWindowInSeconds: Int? = null, startingPosition: PipeMskStartPosition? = null, topicName: String)
Types
Properties
Link copied to clipboard
val credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null