mv test ns consumer.clj into consumer/zk.clj
This commit is contained in:
parent
2f24376609
commit
dd1cdeeb86
1 changed files with 2 additions and 3 deletions
|
@ -1,10 +1,9 @@
|
|||
(ns clj-kafka.test.consumer
|
||||
(ns clj-kafka.test.consumer.zk
|
||||
(:use [expectations]
|
||||
[clj-kafka.core :only (with-resource to-clojure)]
|
||||
[clj-kafka.producer :only (producer send-messages message)]
|
||||
[clj-kafka.test.utils :only (with-test-broker)])
|
||||
(:require [clj-kafka.consumer.zk :as zk]
|
||||
[clj-kafka.consumer.simple :as simp]))
|
||||
(:require [clj-kafka.consumer.zk :as zk]))
|
||||
|
||||
(def producer-config {"metadata.broker.list" "localhost:9999"
|
||||
"serializer.class" "kafka.serializer.DefaultEncoder"
|
Loading…
Reference in a new issue