fileape.avro.writer — fileape 2.0.3

-load-schema clj

(-load-schema k env {:keys [avro-schema-registry-url schema-client]})

Allow schema-client to be passed in, otherwise create one using the avro-schema-registry-url

close! clj

(close! {:keys [data-writer]})

create-client-if-not-exist clj

(create-client-if-not-exist env avro-schema-registry-url)

create-data-writer clj

(create-data-writer file schema avro-codec)

load-schema clj

open-avro-file! clj

(open-avro-file! k file env conf)

If schema-client is added to conf, it will be used instead of creating a schema client

valid-codec clj

(valid-codec codec-name)

write! clj

(write! {:keys [data-writer]} datum)

datum: should be an avro record