Liking cljdoc? Tell your friends :D
Clojure only.

taoensso.timbre.appenders.community.franzy

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

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

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`.
source

naive-key-strategyclj

(naive-key-strategy _)
source

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

Keyboard shortcutsReport a problemcljdoc on GitHub
× close