jackdaw.repl — fundingcircle/jackdaw 0.6.9-word_count_modernization-SNAPSHOT

admin-client-config clj

consumer-config clj

create-topic clj

(create-topic topic-config)

Takes a topic config and creates a Kafka topic.

get-keyvals clj

(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.

get-records clj

(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.

list-topics clj

(list-topics)

Returns a list of Kafka topics.

producer-config clj

publish clj

(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.

topic-exists? clj

(topic-exists? topic-config)

Takes a topic name and returns true if the topic exists.