Package com.google.pubsub.kafka.sink (0.1.1)

Version 0.1.1

• 1.2.0 (latest)
• 1.1.0
• 1.0.0
• 0.1.5

Classes

CloudPubSubSinkConnector

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

CloudPubSubSinkConnector.OrderingKeySource.Validator

Validator class for CloudPubSubSinkConnector.OrderingKeySource.

CloudPubSubSinkTask

A SinkTask used by a CloudPubSubSinkConnector to write messages to Google Cloud Pub/Sub.

Enums

CloudPubSubSinkConnector.OrderingKeySource

Defines the accepted values for the #ORDERING_KEY_SOURCE.