Send feedback
Class CloudPubSubSourceConnector (1.2.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version latestkeyboard_arrow_down
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
maxTasksint
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
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 2025-09-12 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 2025-09-12 UTC."],[],[],null,[]]
