diff options
| author |   Shwetank Dave <shwetank.dave@amdocs.com> | 2019-01-16 12:27:47 -0500 |
|---|---|---|
| committer | Shwetank Dave <shwetank.dave@amdocs.com> | 2019-01-16 12:30:20 -0500 |
| commit | 2210ee587d73dff06ac0711280b0ea8aae3ffa10 (patch) | |
| tree | d1e2eef7819642fa44abb498db3bc136f2a76b92 /src/chameleon/kafka.clj | |
| parent | 694cabe2c0c5aaa05de06e731112b4bf78366de5 (diff) | |
Removing conform from kafkaRecords
Change-Id: Id3648a7286556e683b50da9f3db4bcec62005794
Issue-ID: AAI-797
Signed-off-by: Shwetank Dave <shwetank.dave@amdocs.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) |