Class CloudPubSubSourceConnector (1.2.0)
public class CloudPubSubSourceConnector extends SourceConnector
A SourceConnector that writes messages to a specific topic in Apache Kafka.
Inheritance
java.lang.Object >
org.apache.kafka.connect.connector.Connector >
org.apache.kafka.connect.source.SourceConnector >
CloudPubSubSourceConnector
Inherited Members
org.apache.kafka.connect.connector.Connector.config()
org.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext)
org.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext,java.util.List<java.util.Map<java.lang.String,java.lang.String>>)
org.apache.kafka.connect.connector.Connector.reconfigure(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.connector.Connector.stop()
org.apache.kafka.connect.connector.Connector.taskClass()
org.apache.kafka.connect.connector.Connector.taskConfigs(int)
org.apache.kafka.connect.connector.Connector.validate(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.source.SourceConnector.canDefineTransactionBoundaries(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.source.SourceConnector.context()
org.apache.kafka.connect.source.SourceConnector.exactlyOnceSupport(java.util.Map<java.lang.String,java.lang.String>)
Static Fields
CPS_MAKE_ORDERING_KEY_ATTRIBUTE
public static final String CPS_MAKE_ORDERING_KEY_ATTRIBUTE
Field Value |
Type |
Description |
String |
|
CPS_MAX_BATCH_SIZE_CONFIG
public static final String CPS_MAX_BATCH_SIZE_CONFIG
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_ENABLED
public static final String CPS_STREAMING_PULL_ENABLED
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_FLOW_CONTROL_BYTES
public static final String CPS_STREAMING_PULL_FLOW_CONTROL_BYTES
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_FLOW_CONTROL_MESSAGES
public static final String CPS_STREAMING_PULL_FLOW_CONTROL_MESSAGES
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_MAX_ACK_EXTENSION_MS
public static final String CPS_STREAMING_PULL_MAX_ACK_EXTENSION_MS
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_MAX_MS_PER_ACK_EXTENSION
public static final String CPS_STREAMING_PULL_MAX_MS_PER_ACK_EXTENSION
Field Value |
Type |
Description |
String |
|
CPS_STREAMING_PULL_PARALLEL_STREAMS
public static final String CPS_STREAMING_PULL_PARALLEL_STREAMS
Field Value |
Type |
Description |
String |
|
CPS_SUBSCRIPTION_CONFIG
public static final String CPS_SUBSCRIPTION_CONFIG
Field Value |
Type |
Description |
String |
|
DEFAULT_CPS_MAX_BATCH_SIZE
public static final int DEFAULT_CPS_MAX_BATCH_SIZE
Field Value |
Type |
Description |
int |
|
DEFAULT_KAFKA_PARTITIONS
public static final int DEFAULT_KAFKA_PARTITIONS
Field Value |
Type |
Description |
int |
|
DEFAULT_KAFKA_PARTITION_SCHEME
public static final String DEFAULT_KAFKA_PARTITION_SCHEME
Field Value |
Type |
Description |
String |
|
KAFKA_MESSAGE_KEY_CONFIG
public static final String KAFKA_MESSAGE_KEY_CONFIG
Field Value |
Type |
Description |
String |
|
KAFKA_MESSAGE_TIMESTAMP_CONFIG
public static final String KAFKA_MESSAGE_TIMESTAMP_CONFIG
Field Value |
Type |
Description |
String |
|
KAFKA_PARTITIONS_CONFIG
public static final String KAFKA_PARTITIONS_CONFIG
Field Value |
Type |
Description |
String |
|
KAFKA_PARTITION_SCHEME_CONFIG
public static final String KAFKA_PARTITION_SCHEME_CONFIG
Field Value |
Type |
Description |
String |
|
KAFKA_TOPIC_CONFIG
public static final String KAFKA_TOPIC_CONFIG
Field Value |
Type |
Description |
String |
|
public static final String USE_KAFKA_HEADERS
Field Value |
Type |
Description |
String |
|
Constructors
CloudPubSubSourceConnector()
public CloudPubSubSourceConnector()
Methods
config()
public ConfigDef config()
Returns |
Type |
Description |
org.apache.kafka.common.config.ConfigDef |
|
Overrides
org.apache.kafka.connect.connector.Connector.config()
start(Map<String,String> props)
public void start(Map<String,String> props)
Overrides
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)
stop()
Overrides
org.apache.kafka.connect.connector.Connector.stop()
taskClass()
public Class<? extends Task> taskClass()
Returns |
Type |
Description |
Class<? extends org.apache.kafka.connect.connector.Task> |
|
Overrides
org.apache.kafka.connect.connector.Connector.taskClass()
taskConfigs(int maxTasks)
public List<Map<String,String>> taskConfigs(int maxTasks)
Parameter |
Name |
Description |
maxTasks |
int
|
Overrides
org.apache.kafka.connect.connector.Connector.taskConfigs(int)
verifySubscription(String cpsProject, String cpsSubscription, CredentialsProvider credentialsProvider)
public void verifySubscription(String cpsProject, String cpsSubscription, CredentialsProvider credentialsProvider)
version()
Returns |
Type |
Description |
String |
|
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 2025-10-10 UTC.
[[["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 2025-10-10 UTC."],[],[]]