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