Class ConnectorUtils (1.1.0)
Stay organized with collections
Save and categorize content based on your preferences.
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()
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-03-22 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]