Interface IngestionDataSourceSettings.AwsKinesisOrBuilder (1.135.0) 

public static interface IngestionDataSourceSettings.AwsKinesisOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getAwsRoleArn()

public abstract String getAwsRoleArn()

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

string aws_role_arn = 4 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
String

The awsRoleArn.

getAwsRoleArnBytes()

public abstract ByteString getAwsRoleArnBytes()

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

string aws_role_arn = 4 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
ByteString

The bytes for awsRoleArn.

getConsumerArn()

public abstract String getConsumerArn()

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

string consumer_arn = 3 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
String

The consumerArn.

getConsumerArnBytes()

public abstract ByteString getConsumerArnBytes()

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

string consumer_arn = 3 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
ByteString

The bytes for consumerArn.

getGcpServiceAccount()

public abstract String getGcpServiceAccount()

Required. The GCP service account to be used for Federated Identity authentication with Kinesis (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.

string gcp_service_account = 5 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
String

The gcpServiceAccount.

getGcpServiceAccountBytes()

public abstract ByteString getGcpServiceAccountBytes()

Required. The GCP service account to be used for Federated Identity authentication with Kinesis (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.

string gcp_service_account = 5 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
ByteString

The bytes for gcpServiceAccount.

getState()

public abstract IngestionDataSourceSettings.AwsKinesis.State getState()

Output only. An output-only field that indicates the state of the Kinesis ingestion source.

.google.pubsub.v1.IngestionDataSourceSettings.AwsKinesis.State state = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
Type Description
IngestionDataSourceSettings.AwsKinesis.State

The state.

getStateValue()

public abstract int getStateValue()

Output only. An output-only field that indicates the state of the Kinesis ingestion source.

.google.pubsub.v1.IngestionDataSourceSettings.AwsKinesis.State state = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
Type Description
int

The enum numeric value on the wire for state.

getStreamArn()

public abstract String getStreamArn()

Required. The Kinesis stream ARN to ingest data from.

string stream_arn = 2 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
String

The streamArn.

getStreamArnBytes()

public abstract ByteString getStreamArnBytes()

Required. The Kinesis stream ARN to ingest data from.

string stream_arn = 2 [(.google.api.field_behavior) = REQUIRED];

Returns
Type Description
ByteString

The bytes for streamArn.