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 msg)
Parses deserialized Avro object into a Clojure data structure.
Parses deserialized Avro object into a Clojure data structure.
(->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.
(epoch-days-to-epoch-millis epoch-days)
(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.
(logical-name schema)
(parse-schema json)
A little helper for parsing schemas
A little helper for parsing schemas
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close