Interface IngestionDataSourceSettings.AwsKinesisOrBuilder (1.127.3)

Version latest

• 1.127.3 (latest)
• 1.126.6
• 1.125.13
• 1.123.18
• 1.122.2
• 1.121.1
• 1.120.24
• 1.119.1
• 1.118.0
• 1.117.0
• 1.116.4
• 1.115.5

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.