From 220e170103ae5711addcfd84f597fc06a5e3aaca Mon Sep 17 00:00:00 2001 From: Shwetank Dave Date: Wed, 12 Sep 2018 16:45:03 -0400 Subject: Updating test to fix daily build job. Change-Id: I5dce0888f0e21bb253eee23da6b998480522deb5 Issue-ID: AAI-1547 Signed-off-by: Shwetank Dave --- src/chameleon/specs.clj | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) (limited to 'src/chameleon/specs.clj') diff --git a/src/chameleon/specs.clj b/src/chameleon/specs.clj index 4158e09..760b30a 100644 --- a/src/chameleon/specs.clj +++ b/src/chameleon/specs.clj @@ -5,7 +5,8 @@ [cheshire.core :as c] [clojure.core.async :as ca] [clojure.string :as str] - [cheshire.core :as json]) + [cheshire.core :as json] + [chameleon.kafka :as ck]) (:import [org.apache.kafka.clients.consumer ConsumerRecord] [java.util Properties])) @@ -114,3 +115,11 @@ (s/def :kafka/clojure-consumer-record (s/spec (s/keys :req-un [:kafka/topic :kafka/partition :kafka/offset :kafka/key :kafka/value]))) (s/def :kafka/properties (s/spec #(instance? Properties %) :gen #(s/tuple keyword? ::string))) +(s/def :kafka/consumer (s/spec ck/clj-kafka-comsumer? :gen #(->> (s/cat :config :kafka/config + :group-id ::string + :topic :kafka/topic + :logger ::logger) + s/gen + (gen/fmap (fn [[config group-id topic logger]] + (println [config group-id topic logger]) + (ck/clj-kafka-consumer config group-id topic logger)))))) -- cgit 1.2.3-korg