diff options
| author |   Venkata Harish Kajur <vk250x@att.com> | 2019-01-07 18:15:20 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-01-07 18:15:20 +0000 |
| commit | 1b20fdda530d3325e0a0780fdac5484c6d2093bd (patch) | |
| tree | 08cf91e7c32d15f39e0d1cd289514e9671d90f35 /src/chameleon/kafka.clj | |
| parent | 7bc0c64e94ed084f2144ff3f6d0df11a877c9b72 (diff) | |
| parent | b179d63aeef9beb3ef9d5b4f028af9a716f2faaf (diff) | |
Merge "Update ring dependency, fix event issue" into casablanca3.0.1-ONAP1.3.1casablanca
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) |