blob: 48b8f2ed7eecaf9af3883226f5d1b6ec9287b5bc (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
(ns dev
"Tools for interactive development with the REPL. This file should
not be included in a production build of the application."
(:require [chameleon.config :refer [config]]
[chameleon.handler :refer [handler]]
[integrant.core :as ig]
[chameleon.logging :as log]
[chameleon.specs :as sp]
[integrant.repl :refer [clear go halt init reset reset-all]]
[integrant.repl.state :refer [system]]
[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]]
[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 ""
:pass ""
:consumer-group"chameleon1"
:consumer-id"chameleon1"
:timeout 15000
:batch-size 8
:type "HTTPAUTH"
:kafka-config kafka-config}
:source :kafka}
:gallifrey-host "localhost:443"
:http-port 3449})))
|
