aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorVenkata Harish Kajur <vk250x@att.com>2019-01-07 18:15:20 +0000
committerGerrit Code Review <gerrit@onap.org>2019-01-07 18:15:20 +0000
commit1b20fdda530d3325e0a0780fdac5484c6d2093bd (patch)
tree08cf91e7c32d15f39e0d1cd289514e9671d90f35 /src
parent7bc0c64e94ed084f2144ff3f6d0df11a877c9b72 (diff)
parentb179d63aeef9beb3ef9d5b4f028af9a716f2faaf (diff)
Merge "Update ring dependency, fix event issue" into casablanca3.0.1-ONAP1.3.1casablanca
Diffstat (limited to 'src')
-rw-r--r--src/chameleon/kafka.clj1
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)