diff options
Diffstat (limited to 'src/chameleon/event.clj')
| -rw-r--r-- | src/chameleon/event.clj | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/chameleon/event.clj b/src/chameleon/event.clj index 2eddf85..40592dc 100644 --- a/src/chameleon/event.clj +++ b/src/chameleon/event.clj @@ -39,9 +39,9 @@ [event-config gallifrey-host loggers] (let [{:keys [topic consumer-group processor kafka-config]} (:aai event-config) [error-logger audit-logger] loggers - kfc (ck/clj-kafka-consumer kafka-config consumer-group topic) + kfc (ck/clj-kafka-consumer kafka-config consumer-group topic error-logger) chan (ca/chan 5) - error-chan (ck/subscribe kfc chan 30000 "Polling-Kafka-Thread")] + error-chan (ck/subscribe kfc chan 30000 "Polling-Kafka-Thread" error-logger)] (log/info error-logger "EVENT_PROCESSOR" [(format "AAI created. Starting polling a KAFKA Topic '%s' on '%s'" topic (kafka-config "bootstrap.servers"))]) (ca/go-loop [] |