com.google.api.services.pubsub.model

Class AwsMsk

java.lang.Object

java.util.AbstractMap<String,Object>

com.google.api.client.util.GenericData

com.google.api.client.json.GenericJson

com.google.api.services.pubsub.model.AwsMsk

All Implemented Interfaces:

Cloneable, Map<String,Object>

public final class AwsMsk
extends com.google.api.client.json.GenericJson

Ingestion settings for Amazon MSK.

This is the Java data model class that specifies how to parse/serialize into the JSON that is transmitted over HTTP when working with the Cloud Pub/Sub API. For a detailed explanation see: https://developers.google.com/api-client-library/java/google-http-java-client/json

Author:

Google, Inc.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.api.client.util.GenericData

com.google.api.client.util.GenericData.Flags

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
AwsMsk()

Method Summary

Modifier and Type	Method and Description
AwsMsk	clone()
String	getAwsRoleArn() Required.
String	getClusterArn() Required.
String	getGcpServiceAccount() Required.
String	getState() Output only.
String	getTopic() Required.
AwsMsk	set(String fieldName, Object value)
AwsMsk	setAwsRoleArn(String awsRoleArn) Required.
AwsMsk	setClusterArn(String clusterArn) Required.
AwsMsk	setGcpServiceAccount(String gcpServiceAccount) Required.
AwsMsk	setState(String state) Output only.
AwsMsk	setTopic(String topic) Required.

Methods inherited from class com.google.api.client.json.GenericJson

getFactory, setFactory, toPrettyString, toString

Methods inherited from class com.google.api.client.util.GenericData

entrySet, equals, get, getClassInfo, getUnknownKeys, hashCode, put, putAll, remove, setUnknownKeys

Methods inherited from class java.util.AbstractMap

clear, containsKey, containsValue, isEmpty, keySet, size, values

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Constructor Detail

AwsMsk

public AwsMsk()

Method Detail

getAwsRoleArn

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

Returns:

value or null for none

setAwsRoleArn

public AwsMsk setAwsRoleArn(String awsRoleArn)

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.

Parameters:

awsRoleArn - awsRoleArn or null for none

getClusterArn

public String getClusterArn()

Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.

Returns:

value or null for none

setClusterArn

public AwsMsk setClusterArn(String clusterArn)

Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.

Parameters:

clusterArn - clusterArn or null for none

getGcpServiceAccount

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

Returns:

value or null for none

setGcpServiceAccount

public AwsMsk setGcpServiceAccount(String gcpServiceAccount)

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.

Parameters:

gcpServiceAccount - gcpServiceAccount or null for none

getState

public String getState()

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

Returns:

value or null for none

setState

public AwsMsk setState(String state)

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

Parameters:

state - state or null for none

getTopic

public String getTopic()

Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.

Returns:

value or null for none

setTopic

public AwsMsk setTopic(String topic)

Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.

Parameters:

topic - topic or null for none

set

public AwsMsk set(String fieldName,
                  Object value)

Overrides:

set in class com.google.api.client.json.GenericJson

clone

public AwsMsk clone()

Overrides:

clone in class com.google.api.client.json.GenericJson