Module encode 

Structs

AvroEncoder

Manages encoding of Avro-encoded bytes.

AvroSchemaGenerator

Generates an Avro schema

Enums

AvroSchemaId

Identifies the schema-registry wire framing an AvroEncoder prepends to each record, carrying the registry-specific schema id.

DocTarget

Statics

DEBEZIUM_TRANSACTION_SCHEMA 🔒

Functions

encode_confluent_header 🔒

encode_datums_as_avro

Encodes a sequence of Datum as Avro (key and value), using supplied column names and types.

encode_debezium_transaction_unchecked

encode_message_unchecked 🔒

get_debezium_transaction_schema