clj-kafka-repl
Namespaces
clj-kafka-repl.channel
core.async based functions for use with kafka/consume.
clj-kafka-repl.kafka
Functions for consuming, producing and reading metadata from kafka.
Public variables and functions:
core.async based functions for use with kafka/consume.
Functions for consuming, producing and reading metadata from kafka.
Public variables and functions: