diff options
| author |   C.T. Paterson <ctpaterson+onap@gmail.com> | 2018-09-04 14:05:24 -0400 |
|---|---|---|
| committer | C.T. Paterson <ctpaterson+onap@gmail.com> | 2018-09-04 14:49:55 -0400 |
| commit | d0dceef6a3504a376cc689afc119ef15a56b5f7a (patch) | |
| tree | 6403bf7e70a014860e426589bdeec9fc11401607 /src/chameleon/event.clj | |
| parent | 1586036fd345c240982237b76469a1f5d04d122d (diff) | |
Adding version.properties for build job, tests
Issue-ID: AAI-1547
Change-Id: I70ecf0f427eb30da8df1ec3e2a0cec383e0063fb
Signed-off-by: C.T. Paterson <ctpaterson+onap@gmail.com>
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 [] |