Franzy (Kafka) appender. Requires <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"]}})(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`.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |