diff options
| author |   Shwetank Dave <shwetank.dave@amdocs.com> | 2018-08-24 13:24:49 -0400 |
|---|---|---|
| committer | Shwetank Dave <shwetank.dave@amdocs.com> | 2018-08-30 14:08:19 -0400 |
| commit | 525c7d8dbef106245c4fce29a5b6b31b7160b21c (patch) | |
| tree | 5f24deb3ca219bf7536649d1c89988abb06dbbf3 /dev/dev.clj | |
| parent | e16bda37d76e63e0f903bba13ed1dccf3b17f395 (diff) | |
Updated log messages to be more intuitive
Added support for kafka
Updated logging.clj file to not reject messages which contain an empty substring.
Updating Dockerfile to use the specified GLIBC_VERSION
Adding spotify docker plugin
Moving the Dockerfile to directory root.
Issue-ID: AAI-1542
Change-Id: I4c41486cb6c7698a2c2736d574721f6a5237563e
Signed-off-by: Shwetank Dave <shwetank.dave@amdocs.com>
Diffstat (limited to 'dev/dev.clj')
| -rw-r--r-- | dev/dev.clj | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/dev/dev.clj b/dev/dev.clj index 51d0fdf..48b8f2e 100644 --- a/dev/dev.clj +++ b/dev/dev.clj @@ -11,10 +11,21 @@ [clojure.tools.namespace.repl :refer [refresh refresh-all disable-reload!]] [clojure.repl :refer [apropos dir doc find-doc pst source]] [clojure.test :refer [run-tests run-all-tests]] - [clojure.pprint :refer [pprint]])) + [clojure.pprint :refer [pprint]] + [chameleon.kafka :refer [deser]])) (disable-reload! (find-ns 'integrant.core)) + + + +(def kafka-config {"client.id" "chameleon.developer" + "bootstrap.servers" "host:port" + "key.deserializer" "org.apache.kafka.common.serialization.StringDeserializer" + "value.deserializer" "org.apache.kafka.common.serialization.StringDeserializer" + "enable.auto.commit" "false" + "auto.offset.reset" "earliest"}) + (integrant.repl/set-prep! (constantly (config {:event-config {:aai {:host "localhost:3904" :topic "events" :motsid "" @@ -23,6 +34,8 @@ :consumer-id"chameleon1" :timeout 15000 :batch-size 8 - :type "HTTPAUTH"}} + :type "HTTPAUTH" + :kafka-config kafka-config} + :source :kafka} :gallifrey-host "localhost:443" :http-port 3449}))) |