public static interface IngestionDataSourceSettings.AwsMskOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
getAwsRoleArn()
public abstract String getAwsRoleArn()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.
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 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.
string aws_role_arn = 4 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for awsRoleArn. |
getClusterArn()
public abstract String getClusterArn()Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.
string cluster_arn = 2 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
String |
The clusterArn. |
getClusterArnBytes()
public abstract ByteString getClusterArnBytes()Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.
string cluster_arn = 2 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for clusterArn. |
getGcpServiceAccount()
public abstract String getGcpServiceAccount() 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.
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 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.
string gcp_service_account = 5 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for gcpServiceAccount. |
getState()
public abstract IngestionDataSourceSettings.AwsMsk.State getState()Output only. An output-only field that indicates the state of the Amazon MSK ingestion source.
.google.pubsub.v1.IngestionDataSourceSettings.AwsMsk.State state = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Returns | |
|---|---|
| Type | Description |
IngestionDataSourceSettings.AwsMsk.State |
The state. |
getStateValue()
public abstract int getStateValue()Output only. An output-only field that indicates the state of the Amazon MSK ingestion source.
.google.pubsub.v1.IngestionDataSourceSettings.AwsMsk.State state = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Returns | |
|---|---|
| Type | Description |
int |
The enum numeric value on the wire for state. |
getTopic()
public abstract String getTopic()Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.
string topic = 3 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
String |
The topic. |
getTopicBytes()
public abstract ByteString getTopicBytes()Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.
string topic = 3 [(.google.api.field_behavior) = REQUIRED];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for topic. |