Liking cljdoc? Tell your friends :D

kafkakit.avro

Convert Clojure data structures to Avro-compatible Java classes (not Avro binary format!) back and forth in order to be able to use Schema Registry's serializers with Kafka and Clojure.

Source: https://github.com/konukhov/kfk-avro-bridge

References:

Convert Clojure data structures to Avro-compatible Java classes (not Avro
binary format!) back and forth in order to be able to use Schema Registry's
serializers with Kafka and Clojure.

Source: https://github.com/konukhov/kfk-avro-bridge

References:

  * https://github.com/confluentinc/schema-registry/blob/master/avro-serializer/src/main/java/io/confluent/kafka/serializers/KafkaAvroSerializer.java

->clj

(->clj msg)

Parses deserialized Avro object into a Clojure data structure.

Parses deserialized Avro object into a Clojure data structure.
raw docstring

->java

(->java schema obj)

Converts a Clojure data structure to an Avro-compatible Java object. Avro Schema must be provided.

Converts a Clojure data structure to an Avro-compatible
Java object. Avro `Schema` must be provided.
raw docstring

epoch-days-to-epoch-millis

(epoch-days-to-epoch-millis epoch-days)

fix-epoch-millis

(fix-epoch-millis maybe-epoch-millis)

Sometimes input here must be epoch days and must be converted.

Sometimes input here must be epoch days and must be converted.
raw docstring

logical-name

(logical-name schema)

max-epoch-days


parse-schema

(parse-schema json)

A little helper for parsing schemas

A little helper for parsing schemas
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close