Liking cljdoc? Tell your friends :D
Clojure only.
manifold-kafka.consumer
input-streamclj
(input-stream consumer-config topic)takes a kafka consumer config map and a topic and returns a manifold stream which represents the topic. When the stream is closed, the Kafka Consumer will be shut down. A message is only taken from kafka and put on the stream when the stream contains no messages.
takes a kafka consumer config map and a topic and returns a manifold stream which represents the topic. When the stream is closed, the Kafka Consumer will be shut down. A message is only taken from kafka and put on the stream when the stream contains no messages.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close