From b5eca47aa8d4879af3ae4235615a99af7bb8633a Mon Sep 17 00:00:00 2001 From: Dayo Oliyide Date: Mon, 9 Feb 2015 20:02:45 +0000 Subject: [PATCH] Extend ToClojure protocol to nil --- src/clj_kafka/core.clj | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/clj_kafka/core.clj b/src/clj_kafka/core.clj index 2bbc3cd..a11cc7a 100644 --- a/src/clj_kafka/core.clj +++ b/src/clj_kafka/core.clj @@ -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)))