pipes/aws.sdk.kotlin.services.pipes.model/PipeSourceManagedStreamingKafkaParameters/Builder

Builder

Properties

var batchSize: Int?

The maximum number of records to include in each batch.

consumerGroupId

var consumerGroupId: String?

The name of the destination queue to consume.

var credentials: MskAccessCredentials?

The credentials needed to access the resource.

maximumBatchingWindowInSeconds

var maximumBatchingWindowInSeconds: Int?

The maximum length of a time to wait for events.

startingPosition

var startingPosition: MskStartPosition?

(Streams only) The position in a stream from which to start reading.

var topicName: String?

The name of the topic that the pipe will read from.