Todas as amostras de código do Pub/Sub Lite

Create Lite subscription

Create a Lite subscription with a chosen delivery mode.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

Create Lite topic

Create a single-partition Lite topic and configure its retention period, per partition storage, and publishing throughput scaling factor.

Java Python

View Sample

View in documentation

• Creating and managing Lite topics

Delete Lite subscription

Delete a Lite subscription.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

Delete Lite topic

Delete a Lite topic.

Java Python

View Sample

View in documentation

• Creating and managing Lite topics

Get Lite subscription

Print name, topic path, and delivery config of a Lite subscription.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

Get Lite topic

Print name, retention config, and partition config of a Lite topic.

Java Python

View Sample

View in documentation

• Creating and managing Lite topics

List Lite subscriptions in project

List Lite subscriptions in a project.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

List Lite subscriptions in topic

List Lite subscriptions in a Lite topic.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

List Lite topics

List Lite topics in a project.

Java Python

View Sample

View in documentation

• Creating and managing Lite topics

Publish

Publish messages to a single-partition Lite topic and resolve the publish futures asynchronously.

Java Python

View Sample

View in documentation

• Publishing messages to Lite topics
• Quickstart

Publish messages from Apache Kafka

Publish messages to a Pub/Sub Lite topic using a shim for the Kafka Producer API

Java

View Sample

Publish with batch settings

Publish messages with batch settings.

Java Python

View Sample

View in documentation

• Publishing messages to Lite topics

Publish with custom attributes

Publish messages with custom attributes.

Java Python

View Sample

View in documentation

• Publishing messages to Lite topics

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.

Java Python

View Sample

View in documentation

• Publishing messages to Lite topics

Receive messages in Apache Kafka

Receive messages from a Pub/Sub Lite subscription using a shim for the Kafka Consumer API

Java

View Sample

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.

Java Python

View Sample

View in documentation

• Quickstart
• Receiving messages from Lite subscriptions

Update Lite subscription

Update the delivery mode of a Lite subscription.

Java Python

View Sample

View in documentation

• Creating and managing Lite subscriptions

Update Lite topic

Update the retention period, the scaling factor (throughput capacity), and per partition bytes (storage capacity) of a Lite topic.

Java Python

View Sample

View in documentation

• Creating and managing Lite topics