Franzy (Kafka) appender. Requires Franzy (https://github.com/ymilky/franzy.
Franzy (Kafka) appender. Requires Franzy (https://github.com/ymilky/franzy.
(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"]}})
(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`.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close