Skip to content

Instantly share code, notes, and snippets.

@MichaelBlume
Created March 4, 2013 01:30
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save MichaelBlume/3c0a917e0ab665c75d26 to your computer and use it in GitHub Desktop.
(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