Liking cljdoc? Tell your friends :D

taoensso.timbre.appenders.community.franzy

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

Franzy (Kafka) appender.
Requires Franzy (https://github.com/ymilky/franzy.
raw docstring

franzy-appenderclj

(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"]}})

Returns a Franzy (Kafka) appender:
(franzy-appender
  {:topic "test-topic"
   :kafka-config {:bootstrap.servers ["127.0.0.1:9093"]}})
sourceraw docstring

make-producerclj

(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.

Normally need `:bootstrap.servers` in `kafka-config`.
sourceraw docstring

naive-key-strategyclj

(naive-key-strategy _)
source

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

× close