diff options
| author |   C.T. Paterson <ctpaterson+onap@gmail.com> | 2019-01-04 15:10:19 -0500 |
|---|---|---|
| committer | C.T. Paterson <ctpaterson+onap@gmail.com> | 2019-01-04 15:28:06 -0500 |
| commit | 331cc326e5beac043cec9b9649382a71939ca7ac (patch) | |
| tree | 928192bcbe90916183500950b66518152deaee4d /src/chameleon/kafka.clj | |
| parent | 1d2876b3e23fd186f3a5d0db1c35b6577fe9ca87 (diff) | |
Update ring dependency, fix event issue
Change-Id: I0dbe8690c8b618a8055e3edec982acfe49e1ae80
Issue-ID: AAI-1904
Signed-off-by: C.T. Paterson <ctpaterson+onap@gmail.com>
Diffstat (limited to 'src/chameleon/kafka.clj')
| -rw-r--r-- | src/chameleon/kafka.clj | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/src/chameleon/kafka.clj b/src/chameleon/kafka.clj index bdfc07d..357d68a 100644 --- a/src/chameleon/kafka.clj +++ b/src/chameleon/kafka.clj @@ -99,7 +99,6 @@ (loop [] (let [consumer-records (.poll consumer 0)] (when (and (->> consumer-records - (s/conform :kafka/consumer-record) (map consumer-record->clojure) (send-with-sla-timeout chan sla-timeout)) (try (.commitSync consumer) |