org.apache.flink.streaming.connectors.gcp.pubsub.emulator

Class EmulatorCredentialsProvider

java.lang.Object

org.apache.flink.streaming.connectors.gcp.pubsub.emulator.EmulatorCredentialsProvider

All Implemented Interfaces:

com.google.api.gax.core.CredentialsProvider

public final class EmulatorCredentialsProvider
extends Object
implements com.google.api.gax.core.CredentialsProvider

A CredentialsProvider that simply provides the right credentials that are to be used for connecting to an emulator. NOTE: The Google provided NoCredentials and NoCredentialsProvider do not behave as expected. See https://github.com/googleapis/gax-java/issues/1148

Constructor Summary

Constructors

Constructor and Description
EmulatorCredentialsProvider()

Method Summary

Modifier and Type	Method and Description
static EmulatorCredentialsProvider	create()
com.google.auth.Credentials	getCredentials()

Methods inherited from class java.lang.Object

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

Constructor Detail

EmulatorCredentialsProvider

public EmulatorCredentialsProvider()

Method Detail

getCredentials

public com.google.auth.Credentials getCredentials()

Specified by:

getCredentials in interface com.google.api.gax.core.CredentialsProvider

create

public static EmulatorCredentialsProvider create()