Class CloudPubSubSinkConnector (1.1.0)

public class CloudPubSubSinkConnector extends SinkConnector

A SinkConnector that writes messages to a specified topic in Google Cloud Pub/Sub.

Inheritance

java.lang.Object > org.apache.kafka.connect.connector.Connector > org.apache.kafka.connect.sink.SinkConnector > CloudPubSubSinkConnector

Static Fields

CPS_MESSAGE_BODY_NAME

public static final String CPS_MESSAGE_BODY_NAME
Field Value
TypeDescription
String

DEFAULT_DELAY_THRESHOLD_MS

public static final int DEFAULT_DELAY_THRESHOLD_MS
Field Value
TypeDescription
int

DEFAULT_MAX_BUFFER_BYTES

public static final long DEFAULT_MAX_BUFFER_BYTES
Field Value
TypeDescription
long

DEFAULT_MAX_BUFFER_SIZE

public static final int DEFAULT_MAX_BUFFER_SIZE
Field Value
TypeDescription
int

DEFAULT_MAX_OUTSTANDING_MESSAGES

public static final long DEFAULT_MAX_OUTSTANDING_MESSAGES
Field Value
TypeDescription
long

DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES

public static final long DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES
Field Value
TypeDescription
long

DEFAULT_MESSAGE_BODY_NAME

public static final String DEFAULT_MESSAGE_BODY_NAME
Field Value
TypeDescription
String

DEFAULT_ORDERING_KEY_SOURCE

public static final String DEFAULT_ORDERING_KEY_SOURCE
Field Value
TypeDescription
String

DEFAULT_REQUEST_TIMEOUT_MS

public static final int DEFAULT_REQUEST_TIMEOUT_MS
Field Value
TypeDescription
int

DEFAULT_SHUTDOWN_TIMEOUT_MS

public static final int DEFAULT_SHUTDOWN_TIMEOUT_MS
Field Value
TypeDescription
int

DEFAULT_TOTAL_TIMEOUT_MS

public static final int DEFAULT_TOTAL_TIMEOUT_MS
Field Value
TypeDescription
int

MAX_BUFFER_BYTES_CONFIG

public static final String MAX_BUFFER_BYTES_CONFIG
Field Value
TypeDescription
String

MAX_BUFFER_SIZE_CONFIG

public static final String MAX_BUFFER_SIZE_CONFIG
Field Value
TypeDescription
String

MAX_DELAY_THRESHOLD_MS

public static final String MAX_DELAY_THRESHOLD_MS
Field Value
TypeDescription
String

MAX_OUTSTANDING_MESSAGES

public static final String MAX_OUTSTANDING_MESSAGES
Field Value
TypeDescription
String

MAX_OUTSTANDING_REQUEST_BYTES

public static final String MAX_OUTSTANDING_REQUEST_BYTES
Field Value
TypeDescription
String

MAX_REQUEST_TIMEOUT_MS

public static final String MAX_REQUEST_TIMEOUT_MS
Field Value
TypeDescription
String

MAX_SHUTDOWN_TIMEOUT_MS

public static final String MAX_SHUTDOWN_TIMEOUT_MS
Field Value
TypeDescription
String

MAX_TOTAL_TIMEOUT_MS

public static final String MAX_TOTAL_TIMEOUT_MS
Field Value
TypeDescription
String

ORDERING_KEY_SOURCE

public static final String ORDERING_KEY_SOURCE
Field Value
TypeDescription
String

PUBLISH_KAFKA_HEADERS

public static final String PUBLISH_KAFKA_HEADERS
Field Value
TypeDescription
String

PUBLISH_KAFKA_METADATA

public static final String PUBLISH_KAFKA_METADATA
Field Value
TypeDescription
String

Constructors

CloudPubSubSinkConnector()

public CloudPubSubSinkConnector()

Methods

config()

public ConfigDef config()
Returns
TypeDescription
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)
Parameter
NameDescription
propsMap<String,String>
Overrides
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)

stop()

public void stop()
Overrides
org.apache.kafka.connect.connector.Connector.stop()

taskClass()

public Class<? extends Task> taskClass()
Returns
TypeDescription
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
NameDescription
maxTasksint
Returns
TypeDescription
List<Map<String,String>>
Overrides
org.apache.kafka.connect.connector.Connector.taskConfigs(int)

version()

public String version()
Returns
TypeDescription
String