Merge pull request #40 from DayoOliyide/master

Extend ToClojure protocol to nil
This commit is contained in:
Paul Ingles 2015-02-10 09:34:29 +00:00
commit 61d07ef92f

View file

@ -26,6 +26,9 @@
(to-clojure [x] "Converts type to Clojure structure"))
(extend-protocol ToClojure
nil
(to-clojure [x] nil)
MessageAndMetadata
(to-clojure [x] (KafkaMessage. (.topic x) (.offset x) (.partition x) (.key x) (.message x)))