Reactive Interaction Gateway v3.0.0-alpha.2

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

Interface for event serialization and deserialization. Used to decide which serializer to use, such as Apache Avro.

Link to this section Summary

Functions

add_prefix(headers)
decode_body!(body, binary, opts)
encode_body(body, atom, schema)
encode_body(body, binary, schema_name, schema_registry_host)
remove_prefix(headers)

Link to this section Functions

Link to this function

add_prefix(headers)

View Source

Specs

add_prefix(map()) :: kafka_headers()
Link to this function

decode_body!(body, binary, opts)

View Source

Specs

decode_body!(any(), encode_type(), opts :: []) :: any()
Link to this function

encode_body(body, atom, schema)

View Source

Specs

encode_body(any(), encode_type(), schema_name()) :: any()
Link to this function

encode_body(body, binary, schema_name, schema_registry_host)

View Source
Link to this function

remove_prefix(headers)

View Source

Specs

remove_prefix(kafka_headers()) :: map()