kafka-event-processor.kafka.system

new-system

(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})