TopicIngestionDataSourceSettingsAwsMskArgs

data class TopicIngestionDataSourceSettingsAwsMskArgs(val awsRoleArn: Output<String>, val clusterArn: Output<String>, val gcpServiceAccount: Output<String>, val topic: Output<String>) : ConvertibleToJava<TopicIngestionDataSourceSettingsAwsMskArgs>

Constructors

constructor(awsRoleArn: Output<String>, clusterArn: Output<String>, gcpServiceAccount: Output<String>, topic: Output<String>)

Properties

Link copied to clipboard
val awsRoleArn: Output<String>

AWS role ARN to be used for Federated Identity authentication with MSK. 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 clusterArn: Output<String>

ARN that uniquely identifies the MSK cluster.

Link copied to clipboard

The GCP service account to be used for Federated Identity authentication with MSK (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 topic: Output<String>

The name of the MSK topic that Pub/Sub will import from.

Functions

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