yogsototh/clj-kafka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Extend ToClojure protocol to nil

Browse source
This commit is contained in:
Dayo Oliyide 2015-02-09 20:02:45 +00:00
parent a776d070ae
commit b5eca47aa8
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/clj_kafka/core.clj
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)))