feat(pubsublite): Support Google Managed Kafka backend by brownsuga918 · Pull Request #573 · googleapis/python-pubsublite · GitHub

This PR implements Google Managed Kafka (GMK) backend support for the Python Pub/Sub Lite client.

It matches the Go implementation by adding:

Gating to PublisherClient and SubscriberClient to detect MessagingBackend.MANAGED_KAFKA and route to Kafka-based implementations.
KafkaPublisherClient (sync & async) using confluent_kafka.Producer.
KafkaAsyncSingleSubscriber (used in multiplexed subscriber clients) using confluent_kafka.Consumer with thread-safe offset commits.
Automatic consumer group ID derivation from Pub/Sub Lite subscription path.
Header translation including event time parsing and multi-valued header flattening.
OAuth callback support using Google credentials.

Tested thoroughly with unit tests mocking confluent_kafka.

brownsuga918 added 2 commits June 13, 2026 19:06

feat(pubsublite): add GMK Implementation changes

3c37a09

feat(pubsublite): add GMK subscriber implementation

878703d

brownsuga918 requested review from a team as code owners June 13, 2026 19:36

product-auto-label Bot added the size: xl Pull request size is extra large. label Jun 13, 2026

blunderbuss-gcf Bot assigned johnjcasey Jun 13, 2026

product-auto-label Bot added the api: pubsublite Issues related to the googleapis/python-pubsublite API. label Jun 13, 2026

style: fix lint and formatting

8a52d86

feat(pubsublite): Support Google Managed Kafka backend - #573