AwsEventbridgePipeSourceManagedStreamingKafkaArgs

interface AwsEventbridgePipeSourceManagedStreamingKafkaArgs extends EventbridgePipeSourceKafkaBaseArgs {
batchSize?: Input<number>;
consumerGroupId?: Input<string>;
credentials?: AwsEventbridgePipeSourceBrokerCredentialsArgs;
maximumBatchingWindowInSeconds?: Input<number>;
startingPosition?: Input<'TRIM_HORIZON' | 'LATEST'>;
topicName: Input<string>;
}

Source parameters for a managed streaming Kafka (Amazon MSK) topic.

Hierarchy

EventbridgePipeSourceKafkaBaseArgs
AwsEventbridgePipeSourceManagedStreamingKafkaArgs

Properties

`batchSize: Input<number>`

Inherited from batchSize

Maximum number of records per batch. Maximum value: 10000.

`consumerGroupId: Input<string>`

Inherited from consumerGroupId

Consumer group ID. Maximum length: 200.

`credentials: AwsEventbridgePipeSourceBrokerCredentialsArgs`

Inherited from credentials

Credentials for authenticating to the Kafka cluster.

`maximumBatchingWindowInSeconds: Input<number>`

Inherited from maximumBatchingWindowInSeconds

Maximum time in seconds to wait before dispatching a batch. Maximum value: 300.

`startingPosition: Input<'TRIM_HORIZON' | 'LATEST'>`

Inherited from startingPosition

Starting position in the topic. Valid values: TRIM_HORIZON, LATEST. Triggers replacement.

`topicName: Input<string>`

Inherited from topicName

Kafka topic name to consume. Maximum length: 249. Triggers replacement.