rp.jackdaw.user — com.rentpath/rp-jackdaw-clj 0.0.0

Some handy functions for use in the repl.

admin-config clj

(admin-config)

(admin-config bootstrap-servers)

Convenient helper for building an admin config map given optional bootstrap servers string.

consumer-config clj

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

create-topic clj

(create-topic admin-config topic-config)

Creates a Kafka topic.

default-polling-interval-ms clj

get-keyvals clj

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

get-records clj

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

list-topics clj

(list-topics admin-config)

Returns a list of Kafka topics.

producer-config clj

(producer-config)

(producer-config bootstrap-servers)

Convenient helper for building a producer config map given optional bootstrap servers string.

publish clj

(publish producer-config topic-config value)

(publish producer-config topic-config key value)

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

topic-exists? clj

(topic-exists? admin-config topic-config)

Returns true if the topic exists.