thdr.kfk.avro-bridge.core — org.akvo/kfk.avro-bridge 1.7.0fde6374d8aefc632a35a5bb9d82eddc51a0e832

->clj clj

(->clj msg)

(->clj msg
       {:keys [clj-field-fn] :or {clj-field-fn default-clj-field-fn} :as opts})

Parses deserialized Avro object into a Clojure data structure. Enums will get keywordized and kebab-cased.

It accepts an optional as second argument a map with the options: :clj-field-fn function to apply to the record's fields and map keys. Defaults to (comp keyword ->kebab-case str)

->java clj

(->java schema obj)

(->java schema obj opts)

(->java schema
        obj
        path
        {:keys [java-field-fn ignore-unknown-fields?]
         :or {java-field-fn default-java-field-fn ignore-unknown-fields? false}
         :as opts})

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

It accepts an optional as third argument a map with the options:

:java-field-fn function to apply to the Clojure's map keys when transforming them to Record fields and Map keys. Defaults to (comp name ->snake_case) :ignore-unknown-fields? default to false

default-clj-field-fn clj

default-java-field-fn clj

parse-schema clj

(parse-schema json)

A little helper for parsing schemas