Class ConnectorUtils (1.0.0)

public class ConnectorUtils

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

Inheritance

java.lang.Object > ConnectorUtils

Static Fields

CPS_DEFAULT_ENDPOINT

public static final String CPS_DEFAULT_ENDPOINT
Field Value
TypeDescription
String

CPS_ENDPOINT

public static final String CPS_ENDPOINT
Field Value
TypeDescription
String

CPS_MESSAGE_KEY_ATTRIBUTE

public static final String CPS_MESSAGE_KEY_ATTRIBUTE
Field Value
TypeDescription
String

CPS_ORDERING_KEY_ATTRIBUTE

public static final String CPS_ORDERING_KEY_ATTRIBUTE
Field Value
TypeDescription
String

CPS_PROJECT_CONFIG

public static final String CPS_PROJECT_CONFIG
Field Value
TypeDescription
String

CPS_SUBSCRIPTION_FORMAT

public static final String CPS_SUBSCRIPTION_FORMAT
Field Value
TypeDescription
String

CPS_TOPIC_CONFIG

public static final String CPS_TOPIC_CONFIG
Field Value
TypeDescription
String

GCP_CREDENTIALS_FILE_PATH_CONFIG

public static final String GCP_CREDENTIALS_FILE_PATH_CONFIG
Field Value
TypeDescription
String

GCP_CREDENTIALS_JSON_CONFIG

public static final String GCP_CREDENTIALS_JSON_CONFIG
Field Value
TypeDescription
String

KAFKA_MESSAGE_CPS_BODY_FIELD

public static final String KAFKA_MESSAGE_CPS_BODY_FIELD
Field Value
TypeDescription
String

KAFKA_OFFSET_ATTRIBUTE

public static final String KAFKA_OFFSET_ATTRIBUTE
Field Value
TypeDescription
String

KAFKA_PARTITION_ATTRIBUTE

public static final String KAFKA_PARTITION_ATTRIBUTE
Field Value
TypeDescription
String

KAFKA_TIMESTAMP_ATTRIBUTE

public static final String KAFKA_TIMESTAMP_ATTRIBUTE
Field Value
TypeDescription
String

KAFKA_TOPIC_ATTRIBUTE

public static final String KAFKA_TOPIC_ATTRIBUTE
Field Value
TypeDescription
String

SCHEMA_NAME

public static final String SCHEMA_NAME
Field Value
TypeDescription
String

Static Methods

getSystemExecutor()

public static synchronized ScheduledExecutorService getSystemExecutor()
Returns
TypeDescription
ScheduledExecutorService

Constructors

ConnectorUtils()

public ConnectorUtils()