Module confluent

Functions

extract_avro_header

extract_protobuf_header

extract_schema_id 🔒

Extracts the schema_id placed in front of the serialized message by the confluent stack Optionally expect an empty