public static interface IngestionDataSourceSettings.AwsKinesisOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
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. |