Interface IngestionDataSourceSettings.ConfluentCloudOrBuilder (1.143.0)

public static interface IngestionDataSourceSettings.ConfluentCloudOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getBootstrapServer()

public abstract String getBootstrapServer()

Required. The address of the bootstrap server. The format is url:port.

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

Returns
Type	Description
`String`	The bootstrapServer.

getBootstrapServerBytes()

public abstract ByteString getBootstrapServerBytes()

Required. The address of the bootstrap server. The format is url:port.

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

Returns
Type	Description
`ByteString`	The bytes for bootstrapServer.

getClusterId()

public abstract String getClusterId()

Required. The id of the cluster.

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

Returns
Type	Description
`String`	The clusterId.

getClusterIdBytes()

public abstract ByteString getClusterIdBytes()

Required. The id of the cluster.

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

Returns
Type	Description
`ByteString`	The bytes for clusterId.

getGcpServiceAccount()

public abstract String getGcpServiceAccount()

Required. The GCP service account to be used for Federated Identity authentication with identity_pool_id.

string gcp_service_account = 6 [(.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 identity_pool_id.

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

Returns
Type	Description
`ByteString`	The bytes for gcpServiceAccount.

getIdentityPoolId()

public abstract String getIdentityPoolId()

Required. The id of the identity pool to be used for Federated Identity authentication with Confluent Cloud. See https://docs.confluent.io/cloud/current/security/authenticate/workload-identities/identity-providers/oauth/identity-pools.html#add-oauth-identity-pools.

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

Returns
Type	Description
`String`	The identityPoolId.

getIdentityPoolIdBytes()

public abstract ByteString getIdentityPoolIdBytes()

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

Returns
Type	Description
`ByteString`	The bytes for identityPoolId.

getState()

public abstract IngestionDataSourceSettings.ConfluentCloud.State getState()

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

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

Returns
Type	Description
`IngestionDataSourceSettings.ConfluentCloud.State`	The state.

getStateValue()

public abstract int getStateValue()

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

.google.pubsub.v1.IngestionDataSourceSettings.ConfluentCloud.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 Confluent Cloud cluster that Pub/Sub will import from.

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

Returns
Type	Description
`String`	The topic.

getTopicBytes()

public abstract ByteString getTopicBytes()

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

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

Returns
Type	Description
`ByteString`	The bytes for topic.