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})
````
sourceraw docstring

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

× close