Send feedback
Class ConnectorUtils (1.0.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 1.0.0 keyboard_arrow_down
public class ConnectorUtils
Utility methods and constants that are repeated across one or more classes.
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
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 ()
Constructors
ConnectorUtils()
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-11-19 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-11-19 UTC."],[],[]]
