AwsEventbridgePipeSourceSelfManagedKafkaArgs

interface AwsEventbridgePipeSourceSelfManagedKafkaArgs extends EventbridgePipeSourceKafkaBaseArgs {
additionalBootstrapServers?: Input<Input<string>[]>;
batchSize?: Input<number>;
consumerGroupId?: Input<string>;
credentials?: AwsEventbridgePipeSourceBrokerCredentialsArgs;
maximumBatchingWindowInSeconds?: Input<number>;
serverRootCaCertificate?: Input<string>;
startingPosition?: Input<'TRIM_HORIZON' | 'LATEST'>;
topicName: Input<string>;
vpc?: AwsEventbridgePipeSourceSelfManagedKafkaVpcArgs;
}

Source parameters for a self-managed Apache Kafka cluster.

Hierarchy

EventbridgePipeSourceKafkaBaseArgs
AwsEventbridgePipeSourceSelfManagedKafkaArgs

Properties

`additionalBootstrapServers: Input<Input<string>[]>`

Additional bootstrap server URLs (maximum 2, each up to 300 characters). Triggers replacement.

`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.

`serverRootCaCertificate: Input<string>`

ARN of the Secrets Manager secret used as the root CA certificate.

`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.

`vpc: AwsEventbridgePipeSourceSelfManagedKafkaVpcArgs`

VPC configuration for the self-managed Kafka cluster.