secret

  • Download Gist
gistfile1.clj
Clojure
1 2 3 4 5 6 7 8 9 10 11 12 13
(ann get-streams-map [(IPersistentMap String String)
(IPersistentMap String int) ->
(Map
String
(List
(List Message)))])
(defn get-streams-map [conf topics]
(-> conf make-props ConsumerConfig.
Consumer/createJavaConsumerConnector
not-nil
(.createMessageStreams topics)))
 
; .createMessageStreams comes from here: http://people.apache.org/~joestein/kafka-0.7.1-incubating-docs/kafka/javaapi/consumer/ConsumerConnector.html

Please sign in to comment on this gist.

Something went wrong with that request. Please try again.