Created

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist
View gist:3c0a917e0ab665c75d26
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.