Class ConnectorUtils (0.1.5)

public class ConnectorUtils

Utility methods and constants that are repeated across one or more classes.

Inheritance

java.lang.Object > ConnectorUtils

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Fields

CPS_DEFAULT_ENDPOINT

public static final String CPS_DEFAULT_ENDPOINT

Field Value

Type	Description
String

CPS_ENDPOINT

public static final String CPS_ENDPOINT

Field Value

Type	Description
String

CPS_MESSAGE_KEY_ATTRIBUTE

public static final String CPS_MESSAGE_KEY_ATTRIBUTE

Field Value

Type	Description
String

CPS_ORDERING_KEY_ATTRIBUTE

public static final String CPS_ORDERING_KEY_ATTRIBUTE

Field Value

Type	Description
String

CPS_PROJECT_CONFIG

public static final String CPS_PROJECT_CONFIG

Field Value

Type	Description
String

CPS_SUBSCRIPTION_FORMAT

public static final String CPS_SUBSCRIPTION_FORMAT

Field Value

Type	Description
String

CPS_TOPIC_CONFIG

public static final String CPS_TOPIC_CONFIG

Field Value

Type	Description
String

GCP_CREDENTIALS_FILE_PATH_CONFIG

public static final String GCP_CREDENTIALS_FILE_PATH_CONFIG

Field Value

Type	Description
String

GCP_CREDENTIALS_JSON_CONFIG

public static final String GCP_CREDENTIALS_JSON_CONFIG

Field Value

Type	Description
String

KAFKA_MESSAGE_CPS_BODY_FIELD

public static final String KAFKA_MESSAGE_CPS_BODY_FIELD

Field Value

Type	Description
String

KAFKA_OFFSET_ATTRIBUTE

public static final String KAFKA_OFFSET_ATTRIBUTE

Field Value

Type	Description
String

KAFKA_PARTITION_ATTRIBUTE

public static final String KAFKA_PARTITION_ATTRIBUTE

Field Value

Type	Description
String

KAFKA_TIMESTAMP_ATTRIBUTE

public static final String KAFKA_TIMESTAMP_ATTRIBUTE

Field Value

Type	Description
String

KAFKA_TOPIC_ATTRIBUTE

public static final String KAFKA_TOPIC_ATTRIBUTE

Field Value

Type	Description
String

SCHEMA_NAME

public static final String SCHEMA_NAME

Field Value

Type	Description
String

Static Methods

getSystemExecutor()

public static synchronized ScheduledExecutorService getSystemExecutor()

Returns

Type	Description
ScheduledExecutorService

Constructors

ConnectorUtils()

public ConnectorUtils()