View in documentation
Create Lite topic
Create a single-partition Lite topic and configure its retention period, per partition storage, and publishing throughput scaling factor.
View in documentation
View in documentation
View in documentation
Get Lite subscription
Print name, topic path, and delivery config of a Lite subscription.
View in documentation
View in documentation
View in documentation
View in documentation
View in documentation
Publish
Publish messages to a single-partition Lite topic and resolve the publish futures asynchronously.
View in documentation
Publish messages from Apache Kafka
Publish messages to a Pub/Sub Lite topic using a shim for the Kafka Producer API
View in documentation
View in documentation
View in documentation
Publish with ordering keys
Publish messages with an ordering key. Ordering keys are hashed to map to a partition. Messages of the same ordering key get published to the same partition. If the partition is filled up, oldest messages get written over.
View in documentation
Receive messages in Apache Kafka
Receive messages from a Pub/Sub Lite subscription using a shim for the Kafka Consumer API
View in documentation
Subscribe
Use a multi-partition and flow-controlled subscriber (a collection of subscribers) to subscribe to a multiple-partition topic and process messages asynchronously in callbacks.
View in documentation
View in documentation
Update Lite topic
Update the retention period, the scaling factor (throughput capacity), and per partition bytes (storage capacity) of a Lite topic.
View in documentation