summaryrefslogtreecommitdiffstats
path: root/dev/dev.clj
diff options
context:
space:
mode:
authorShwetank Dave <shwetank.dave@amdocs.com>2018-08-24 13:24:49 -0400
committerShwetank Dave <shwetank.dave@amdocs.com>2018-08-30 14:08:19 -0400
commit525c7d8dbef106245c4fce29a5b6b31b7160b21c (patch)
tree5f24deb3ca219bf7536649d1c89988abb06dbbf3 /dev/dev.clj
parente16bda37d76e63e0f903bba13ed1dccf3b17f395 (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.clj17
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})))