PipeSourceManagedStreamingKafkaParameters

import type { PipeSourceManagedStreamingKafkaParameters } from "https://aws-api.deno.dev/v0.4/services/pipes.ts?docs=full";

The parameters for using an MSK stream as a source.

interface PipeSourceManagedStreamingKafkaParameters {

BatchSize?: number | null;

ConsumerGroupID?: string | null;

Credentials?: MSKAccessCredentials | null;

MaximumBatchingWindowInSeconds?: number | null;

StartingPosition?: MSKStartPosition | null;

TopicName: string;

}

§Properties

BatchSize?: number | null

The maximum number of records to include in each batch.

ConsumerGroupID?: string | null

The name of the destination queue to consume.

Credentials?: MSKAccessCredentials | null

The credentials needed to access the resource.

MaximumBatchingWindowInSeconds?: number | null

The maximum length of a time to wait for events.

StartingPosition?: MSKStartPosition | null

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

TopicName: string

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