Cloud Pub/Sub V1 API - Class Google::Cloud::PubSub::V1::IngestionDataSourceSettings::AwsMsk (v1.5.0)

Reference documentation and code samples for the Cloud Pub/Sub V1 API class Google::Cloud::PubSub::V1::IngestionDataSourceSettings::AwsMsk.

Ingestion settings for Amazon MSK.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#aws_role_arn

def aws_role_arn() -> ::String
Returns
  • (::String) — Required. AWS role ARN to be used for Federated Identity authentication with Amazon MSK. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it.

#aws_role_arn=

def aws_role_arn=(value) -> ::String
Parameter
  • value (::String) — Required. AWS role ARN to be used for Federated Identity authentication with Amazon MSK. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it.
Returns
  • (::String) — Required. AWS role ARN to be used for Federated Identity authentication with Amazon MSK. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it.

#cluster_arn

def cluster_arn() -> ::String
Returns
  • (::String) — Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.

#cluster_arn=

def cluster_arn=(value) -> ::String
Parameter
  • value (::String) — Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.
Returns
  • (::String) — Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.

#gcp_service_account

def gcp_service_account() -> ::String
Returns
  • (::String) — Required. The GCP service account to be used for Federated Identity authentication with Amazon MSK (via a AssumeRoleWithWebIdentity call for the provided role). The aws_role_arn must be set up with accounts.google.com:sub equals to this service account number.

#gcp_service_account=

def gcp_service_account=(value) -> ::String
Parameter
  • value (::String) — Required. The GCP service account to be used for Federated Identity authentication with Amazon MSK (via a AssumeRoleWithWebIdentity call for the provided role). The aws_role_arn must be set up with accounts.google.com:sub equals to this service account number.
Returns
  • (::String) — Required. The GCP service account to be used for Federated Identity authentication with Amazon MSK (via a AssumeRoleWithWebIdentity call for the provided role). The aws_role_arn must be set up with accounts.google.com:sub equals to this service account number.

#state

def state() -> ::Google::Cloud::PubSub::V1::IngestionDataSourceSettings::AwsMsk::State
Returns

#topic

def topic() -> ::String
Returns
  • (::String) — Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.

#topic=

def topic=(value) -> ::String
Parameter
  • value (::String) — Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.
Returns
  • (::String) — Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.