Class CloudPubSubSinkConnector (0.1.1)

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

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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.sink.SinkConnector.context()

Static Fields

CPS_MESSAGE_BODY_NAME

public static final String CPS_MESSAGE_BODY_NAME

Field Value

Type	Description
String

DEFAULT_DELAY_THRESHOLD_MS

public static final int DEFAULT_DELAY_THRESHOLD_MS

Field Value

Type	Description
int

DEFAULT_MAX_BUFFER_BYTES

public static final long DEFAULT_MAX_BUFFER_BYTES

Field Value

Type	Description
long

DEFAULT_MAX_BUFFER_SIZE

public static final int DEFAULT_MAX_BUFFER_SIZE

Field Value

Type	Description
int

DEFAULT_MAX_OUTSTANDING_MESSAGES

public static final long DEFAULT_MAX_OUTSTANDING_MESSAGES

Field Value

Type	Description
long

DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES

public static final long DEFAULT_MAX_OUTSTANDING_REQUEST_BYTES

Field Value

Type	Description
long

DEFAULT_MESSAGE_BODY_NAME

public static final String DEFAULT_MESSAGE_BODY_NAME

Field Value

Type	Description
String

DEFAULT_ORDERING_KEY_SOURCE

public static final String DEFAULT_ORDERING_KEY_SOURCE

Field Value

Type	Description
String

DEFAULT_REQUEST_TIMEOUT_MS

public static final int DEFAULT_REQUEST_TIMEOUT_MS

Field Value

Type	Description
int

DEFAULT_SHUTDOWN_TIMEOUT_MS

public static final int DEFAULT_SHUTDOWN_TIMEOUT_MS

Field Value

Type	Description
int

DEFAULT_TOTAL_TIMEOUT_MS

public static final int DEFAULT_TOTAL_TIMEOUT_MS

Field Value

Type	Description
int

MAX_BUFFER_BYTES_CONFIG

public static final String MAX_BUFFER_BYTES_CONFIG

Field Value

Type	Description
String

MAX_BUFFER_SIZE_CONFIG

public static final String MAX_BUFFER_SIZE_CONFIG

Field Value

Type	Description
String

MAX_DELAY_THRESHOLD_MS

public static final String MAX_DELAY_THRESHOLD_MS

Field Value

Type	Description
String

MAX_OUTSTANDING_MESSAGES

public static final String MAX_OUTSTANDING_MESSAGES

Field Value

Type	Description
String

MAX_OUTSTANDING_REQUEST_BYTES

public static final String MAX_OUTSTANDING_REQUEST_BYTES

Field Value

Type	Description
String

MAX_REQUEST_TIMEOUT_MS

public static final String MAX_REQUEST_TIMEOUT_MS

Field Value

Type	Description
String

MAX_SHUTDOWN_TIMEOUT_MS

public static final String MAX_SHUTDOWN_TIMEOUT_MS

Field Value

Type	Description
String

MAX_TOTAL_TIMEOUT_MS

public static final String MAX_TOTAL_TIMEOUT_MS

Field Value

Type	Description
String

ORDERING_KEY_SOURCE

public static final String ORDERING_KEY_SOURCE

Field Value

Type	Description
String

PUBLISH_KAFKA_HEADERS

public static final String PUBLISH_KAFKA_HEADERS

Field Value

Type	Description
String

PUBLISH_KAFKA_METADATA

public static final String PUBLISH_KAFKA_METADATA

Field Value

Type	Description
String

Constructors

CloudPubSubSinkConnector()

public CloudPubSubSinkConnector()

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)

Parameter

Name	Description
props	`Map<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

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`

Returns

Type	Description
List<Map<String,String>>

Overrides

org.apache.kafka.connect.connector.Connector.taskConfigs(int)

version()

public String version()

Returns

Type	Description
String