taoensso.timbre.appenders.community.franzy

Franzy (Kafka) appender.
Requires <https://github.com/ymilky/franzy>.

franzy-appender

clj

(franzy-appender {:keys [topic entry-fn], :or {entry-fn default-entry-fn}, :as config})
Returns a Franzy (Kafka) appender:
(franzy-appender
  {:topic "test-topic"
   :kafka-config {:bootstrap.servers ["127.0.0.1:9093"]}})

make-producer

clj

(make-producer {:keys [kafka-config key-serializer value-serializer], :or {key-serializer serializers/string-serializer, value-serializer serializers/edn-serializer}})
Normally need `:bootstrap.servers` in `kafka-config`.

naive-key-strategy

clj

(naive-key-strategy _)