Package io.github.flink.gcp.connector.pubsub

Class PubSubCredentials

java.lang.Object

io.github.flink.gcp.connector.pubsub.PubSubCredentials

@Internal
public final class PubSubCredentials
extends Object

Loads the credentials shared by the Pub/Sub source and sink client families.

Method Summary

Modifier and Type	Method	Description
static com.google.api.gax.core.CredentialsProvider	load(String serviceAccountKeyFile)	Loads a service-account key file, or returns null to leave application-default credentials in effect.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

load

@Nullable
public static com.google.api.gax.core.CredentialsProvider load(@Nullable
 String serviceAccountKeyFile)
                                                        throws IOException

Loads a service-account key file, or returns null to leave application-default credentials in effect.

A failure names only the product, never the path or the parser's exception; ServiceAccountKeys.load(String, java.util.Collection, String) owns that rule.

Parameters:

serviceAccountKeyFile - the configured key-file path, or null for ADC

Returns:

a fixed provider for the service account, or null for ADC

Throws:

IOException - if the configured file cannot be read as a service-account key