[[["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-08-28 UTC."],[],[],null,["# Class CloudPubSubSinkConnector (1.2.0)\n\nVersion latestkeyboard_arrow_down\n\n- [1.2.0 (latest)](/java/docs/reference/pubsub-group-kafka-connector/latest/com.google.pubsub.kafka.sink.CloudPubSubSinkConnector)\n- [1.1.0](/java/docs/reference/pubsub-group-kafka-connector/1.1.0/com.google.pubsub.kafka.sink.CloudPubSubSinkConnector)\n- [1.0.0](/java/docs/reference/pubsub-group-kafka-connector/1.0.0/com.google.pubsub.kafka.sink.CloudPubSubSinkConnector)\n- [0.1.5](/java/docs/reference/pubsub-group-kafka-connector/0.1.5/com.google.pubsub.kafka.sink.CloudPubSubSinkConnector) \n\n public class CloudPubSubSinkConnector extends SinkConnector\n\nA SinkConnector that writes messages to a specified topic in [Google Cloud Pub/Sub](https://cloud.google.com/pubsub). \n\nInheritance\n-----------\n\n[java.lang.Object](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html) \\\u003e org.apache.kafka.connect.connector.Connector \\\u003e org.apache.kafka.connect.sink.SinkConnector \\\u003e CloudPubSubSinkConnector \n\nInherited Members\n-----------------\n\n[Object.clone()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#clone--) \n[Object.equals(Object)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#equals-java.lang.Object-) \n[Object.finalize()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#finalize--) \n[Object.getClass()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#getClass--) \n[Object.hashCode()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#hashCode--) \n[Object.notify()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notify--) \n[Object.notifyAll()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notifyAll--) \n[Object.toString()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#toString--) \n[Object.wait()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait--) \n[Object.wait(long)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-) \n[Object.wait(long,int)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-int-) \norg.apache.kafka.connect.connector.Connector.config() \norg.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext) \norg.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext,java.util.List\\\u003cjava.util.Map\\\u003cjava.lang.String,java.lang.String\\\u003e\\\u003e) \norg.apache.kafka.connect.connector.Connector.reconfigure(java.util.Map\\\u003cjava.lang.String,java.lang.String\\\u003e) \norg.apache.kafka.connect.connector.Connector.start(java.util.Map\\\u003cjava.lang.String,java.lang.String\\\u003e) \norg.apache.kafka.connect.connector.Connector.stop() \norg.apache.kafka.connect.connector.Connector.taskClass() \norg.apache.kafka.connect.connector.Connector.taskConfigs(int) \norg.apache.kafka.connect.connector.Connector.validate(java.util.Map\\\u003cjava.lang.String,java.lang.String\\\u003e) \norg.apache.kafka.connect.sink.SinkConnector.context()\n\nStatic Fields\n-------------\n\n### COMPRESSION_BYTES_THRESHOLD\n\n public static final String COMPRESSION_BYTES_THRESHOLD\n\n### CPS_MESSAGE_BODY_NAME\n\n public static final String CPS_MESSAGE_BODY_NAME\n\n### DEFAULT_COMPRESSION_BYTES_THRESHOLD\n\n public static final long DEFAULT_COMPRESSION_BYTES_THRESHOLD\n\n### DEFAULT_DELAY_THRESHOLD_MS\n\n public static final int DEFAULT_DELAY_THRESHOLD_MS\n\n### DEFAULT_ENABLE_COMPRESSION\n\n public static final boolean DEFAULT_ENABLE_COMPRESSION\n\n### DEFAULT_MAX_BUFFER_BYTES\n\n public static final long DEFAULT_MAX_BUFFER_BYTES\n\n### DEFAULT_MAX_BUFFER_SIZE\n\n public static final int DEFAULT_MAX_BUFFER_SIZE\n\n### DEFAULT_MAX_OUTSTANDING_MESSAGES\n\n public static final long DEFAULT_MAX_OUTSTANDING_MESSAGES\n\n### DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES\n\n public static final long DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES\n\n### DEFAULT_MESSAGE_BODY_NAME\n\n public static final String DEFAULT_MESSAGE_BODY_NAME\n\n### DEFAULT_ORDERING_KEY_SOURCE\n\n public static final String DEFAULT_ORDERING_KEY_SOURCE\n\n### DEFAULT_REQUEST_TIMEOUT_MS\n\n public static final int DEFAULT_REQUEST_TIMEOUT_MS\n\n### DEFAULT_SHUTDOWN_TIMEOUT_MS\n\n public static final int DEFAULT_SHUTDOWN_TIMEOUT_MS\n\n### DEFAULT_TOTAL_TIMEOUT_MS\n\n public static final int DEFAULT_TOTAL_TIMEOUT_MS\n\n### ENABLE_COMPRESSION\n\n public static final String ENABLE_COMPRESSION\n\n### MAX_BUFFER_BYTES_CONFIG\n\n public static final String MAX_BUFFER_BYTES_CONFIG\n\n### MAX_BUFFER_SIZE_CONFIG\n\n public static final String MAX_BUFFER_SIZE_CONFIG\n\n### MAX_DELAY_THRESHOLD_MS\n\n public static final String MAX_DELAY_THRESHOLD_MS\n\n### MAX_OUTSTANDING_MESSAGES\n\n public static final String MAX_OUTSTANDING_MESSAGES\n\n### MAX_OUTSTANDING_REQUEST_BYTES\n\n public static final String MAX_OUTSTANDING_REQUEST_BYTES\n\n### MAX_REQUEST_TIMEOUT_MS\n\n public static final String MAX_REQUEST_TIMEOUT_MS\n\n### MAX_SHUTDOWN_TIMEOUT_MS\n\n public static final String MAX_SHUTDOWN_TIMEOUT_MS\n\n### MAX_TOTAL_TIMEOUT_MS\n\n public static final String MAX_TOTAL_TIMEOUT_MS\n\n### ORDERING_KEY_SOURCE\n\n public static final String ORDERING_KEY_SOURCE\n\n### PUBLISH_KAFKA_HEADERS\n\n public static final String PUBLISH_KAFKA_HEADERS\n\n### PUBLISH_KAFKA_METADATA\n\n public static final String PUBLISH_KAFKA_METADATA\n\nConstructors\n------------\n\n### CloudPubSubSinkConnector()\n\n public CloudPubSubSinkConnector()\n\nMethods\n-------\n\n### config()\n\n public ConfigDef config()\n\n**Overrides** \norg.apache.kafka.connect.connector.Connector.config()\n\n### start(Map\\\u003cString,String\\\u003e props)\n\n public void start(Map\u003cString,String\u003e props)\n\n**Overrides** \norg.apache.kafka.connect.connector.Connector.start(java.util.Map\\\u003cjava.lang.String,java.lang.String\\\u003e)\n\n### stop()\n\n public void stop()\n\n**Overrides** \norg.apache.kafka.connect.connector.Connector.stop()\n\n### taskClass()\n\n public Class\u003c? extends Task\u003e taskClass()\n\n**Overrides** \norg.apache.kafka.connect.connector.Connector.taskClass()\n\n### taskConfigs(int maxTasks)\n\n public List\u003cMap\u003cString,String\u003e\u003e taskConfigs(int maxTasks)\n\n**Overrides** \norg.apache.kafka.connect.connector.Connector.taskConfigs(int)\n\n### version()\n\n public String version()"]]
