Liking cljdoc? Tell your friends :D
Clojure only.
kafka-event-processor.kafka.system
new-systemclj
(new-system configuration-overrides)(new-system configuration-overrides
{:keys [kafka kafka-configuration configuration-prefix
kafka-enabled]
:or {kafka :kafka
kafka-configuration :kafka-configuration
kafka-enabled :kafka-enabled?
configuration-prefix :service}})Creates a new kafka consumer client.
- Configuration prefix to be specified (defaults to :service).
All system map keys can be overridden or they default where applicable:
- kafka: :kafka
- kafka-configuration: :kafka-configuration
e.g.
(kafka-system/new-system
configuration-overrides
{:kafka :kafka})
Creates a new kafka consumer client.
* Configuration prefix to be specified (defaults to :service).
All system map keys can be overridden or they default where applicable:
* kafka: :kafka
* kafka-configuration: :kafka-configuration
e.g.
````
(kafka-system/new-system
configuration-overrides
{:kafka :kafka})
````
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close