RigKafka.Avro (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Module responsible for event serialization and deserialization. Manages also connection to Kafka Schema Registry and caching of used schemas.

Link to this section Summary

decode(any(), schema_host()) :: String.t()

encode(schema_name(), any(), schema_host()) :: avro_binary()

encoder(schema(), list()) :: any()

fetch_schema(any(), schema_host()) :: {id(), schema()}