A builder for a PubSub Lite Publisher. Basic usage:
Publisher<Offset> publisher = PublisherBuilder.builder() .setTopic( TopicPath.newBuilder() .setProject(MY_PROJECT) .setName(MY_TOPIC) .setLocation(CloudZone.of("us-east1-a")) .build()) .setPartition(Partition.of(10)) .build();
A custom service client can also be set.
A context for identifying clients based on basic properties.
A unique string representing the unambiguous name of a framework in SCREAMING_SNAKE_CASE.
Setting this value will be used to track framework popularity in internal metrics.
A SingleConnection handles the state for a stream with an initial connection request that may only be sent once and needs to wait for a response before sending other requests.
An Assigner is responsible for handling partition assignments for a subscribing client.
A receiver for partition assignments. All updates to reflect the assignment should be performed inline.
A generic PubSub Lite subscriber. Errors are handled out of band. Messages are sent out of band. Thread safe.