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:13:41 -0500 |
| commit | ea74a53b42477d2cd6fdc7cfabb9b92bbdf297c3 (patch) | |
| tree | 67120333b5975638341fcda2d6af396f59a8dc64 /src/chameleon/kafka.clj | |
| parent | 694cabe2c0c5aaa05de06e731112b4bf78366de5 (diff) | |
Update ring dependency, fix event issue
Change-Id: If06c7e9baf04c647a62570aa828ad9d39a4bbf66
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) |