rp.jackdaw.user
Some handy functions for use in the repl.
Some handy functions for use in the repl.
admin-configclj
(admin-config)(admin-config bootstrap-servers)Convenient helper for building an admin config map given optional bootstrap servers string.
Convenient helper for building an admin config map given optional bootstrap servers string.
consumer-configclj
(consumer-config)(consumer-config bootstrap-servers)(consumer-config bootstrap-servers group-id)Convenient helper for building a consumer config map given optional bootstrap servers string and group id.
group-id defaults to a random UUID.
bootstrap-servers defaults to default port on localhost.
Convenient helper for building a consumer config map given optional bootstrap servers string and group id. `group-id` defaults to a random UUID. `bootstrap-servers` defaults to default port on localhost.
create-topic!clj
(create-topic! admin-config topic-config)Creates a single Kafka topic given a topic config.
Creates a single Kafka topic given a topic config.
create-topics!clj
(create-topics! admin-config topic-configs)Create multiple Kafka topics given a sequence of topic configs.
Create multiple Kafka topics given a sequence of topic configs.
delete-topic!clj
(delete-topic! admin-config topic-config)Delete a single Kafka topic given a topic config.
Delete a single Kafka topic given a topic config.
delete-topics!clj
(delete-topics! admin-config topic-configs)Delete multiple Kafka topics given a sequence of topic configs.
Delete multiple Kafka topics given a sequence of topic configs.
get-keyvalsclj
(get-keyvals consumer-config topic-config)(get-keyvals consumer-config topic-config polling-interval-ms)Takes a consumer config and topic config, consumes from a Kafka topic, and returns a seq of key-value pairs.
Takes a consumer config and topic config, consumes from a Kafka topic, and returns a seq of key-value pairs.
get-recordsclj
(get-records consumer-config topic-config)(get-records consumer-config topic-config polling-interval-ms)Takes a consumer config and topic config, consumes from a Kafka topic, and returns a seq of maps.
Takes a consumer config and topic config, consumes from a Kafka topic, and returns a seq of maps.
list-topicsclj
(list-topics admin-config)Returns a list of Kafka topics.
Returns a list of Kafka topics.
produce!clj
(produce! producer-config topic-config value)(produce! producer-config topic-config key value)(produce! producer-config topic-config partition key value)Takes a producer config, topic config and record value, and (optionally) a key and partition number, and produces to a Kafka topic.
Takes a producer config, topic config and record value, and (optionally) a key and partition number, and produces to a Kafka topic.
producer-configclj
(producer-config)(producer-config bootstrap-servers)Convenient helper for building a producer config map given optional bootstrap servers string.
Convenient helper for building a producer config map given optional bootstrap servers string.
re-delete-topics!clj
(re-delete-topics! admin-config re)Takes an instance of java.util.regex.Pattern and deletes any Kafka topics that match.
Takes an instance of java.util.regex.Pattern and deletes any Kafka topics that match.
topic-exists?clj
(topic-exists? admin-config topic-config)Returns true if a topic exists with the name specified in the given topic config.
Returns true if a topic exists with the name specified in the given topic config.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close