TopicIngestionDataSourceSettingsAwsKinesisArgs

data class TopicIngestionDataSourceSettingsAwsKinesisArgs(val awsRoleArn: Output<String>, val consumerArn: Output<String>, val gcpServiceAccount: Output<String>, val streamArn: Output<String>) : ConvertibleToJava<TopicIngestionDataSourceSettingsAwsKinesisArgs>

Constructors

constructor(awsRoleArn: Output<String>, consumerArn: Output<String>, gcpServiceAccount: Output<String>, streamArn: Output<String>)

Properties

Link copied to clipboard
val awsRoleArn: Output<String>

AWS role ARN to be used for Federated Identity authentication with Kinesis. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it.

Link copied to clipboard
val consumerArn: Output<String>

The Kinesis consumer ARN to used for ingestion in Enhanced Fan-Out mode. The consumer must be already created and ready to be used.

Link copied to clipboard

The GCP service account to be used for Federated Identity authentication with Kinesis (via a AssumeRoleWithWebIdentity call for the provided role). The awsRoleArn must be set up with accounts.google.com:sub equals to this service account number.

Link copied to clipboard
val streamArn: Output<String>

The Kinesis stream ARN to ingest data from.

Functions

Link copied to clipboard
open override fun toJava(): TopicIngestionDataSourceSettingsAwsKinesisArgs