(create-topic topic-config)Takes a topic config and creates a Kafka topic.
Takes a topic config and creates a Kafka topic.
(get-keyvals topic-config)(get-keyvals topic-config polling-interval-ms)Takes a topic config, consumes from a Kafka topic, and returns a seq of key-value pairs.
Takes a topic config, consumes from a Kafka topic, and returns a seq of key-value pairs.
(get-records topic-config)(get-records topic-config polling-interval-ms)Takes a topic config, consumes from a Kafka topic, and returns a seq of maps.
Takes a topic config, consumes from a Kafka topic, and returns a seq of maps.
(list-topics)Returns a list of Kafka topics.
Returns a list of Kafka topics.
(publish topic-config value)(publish topic-config key value)(publish topic-config partition key value)Takes a topic config and record value, and (optionally) a key and parition number, and produces to a Kafka topic.
Takes a topic config and record value, and (optionally) a key and parition number, and produces to a Kafka topic.
(topic-exists? topic-config)Takes a topic name and returns true if the topic exists.
Takes a topic name and returns true if the topic exists.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |