Classes
AckBatchingSubscriber
CloudPubSubGRPCSubscriber
A CloudPubSubSubscriber that uses gRPC to pull messages from Google Cloud Pub/Sub. This class is not thread-safe.
CloudPubSubRoundRobinSubscriber
A CloudPubSubSubscriber that distributes a single subscription in round-robin fashion over a set of CloudPubSubGRPCSubscribers.
CloudPubSubSourceConnector
A SourceConnector that writes messages to a specific topic in Apache Kafka.
CloudPubSubSourceConnector.PartitionScheme.Validator
Validator class for CloudPubSubSourceConnector.PartitionScheme.
CloudPubSubSourceTask
A SourceTask used by a CloudPubSubSourceConnector to write messages to Apache Kafka. Due to at-last-once semantics in Google Cloud Pub/Sub duplicates in Kafka are possible.
StreamingPullSubscriber
Interfaces
CloudPubSubSubscriber
An interface for clients that want to subscribe to messages from to Google Cloud Pub/Sub.
StreamingPullSubscriberFactory
Enums
CloudPubSubSourceConnector.PartitionScheme
Defines the accepted values for the #KAFKA_PARTITION_SCHEME_CONFIG.