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

PipeSourceManagedStreamingKafkaParameters

The parameters for using an MSK stream as a source.

Types

The maximum number of records to include in each batch.

The name of the destination queue to consume.

The credentials needed to access the resource.

The maximum length of a time to wait for events.

The position in a stream from which to start reading.

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

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

open override fun toString(): String