Module pulsar_schema 

Modules

client 🔒

schema 🔒

Structs

Client

HTTP client for Pulsar schemas. The configured Admin endpoint and the brokers it redirects to are trusted to receive the schema bearer token. Authenticated requests require HTTPS at every hop.

PulsarSchemaConfig

PulsarSchemaInfo

PulsarSchemaVersion

Enums

PulsarSchema

A Pulsar schema by type. Pulsar stores both AVRO and JSON schemas as Avro record definitions, but their payloads are Avro binary and plain JSON respectively.

Constants

PULSAR_SCHEMA_AUTH_TOKEN_KEY

PULSAR_SCHEMA_URL_KEY

Functions

parse_partitioned_topic

Returns the partitioned topic, i.e. the topic without partition suffix, as schemas are shared by all partitions.