Skip to content

@MichaelBlume /gist:3c0a917e0ab665c75d26 secret
Created

Embed URL

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
(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.