lib-kafka.kafka — org.clojars.adolfofukuda/lib-kafka 0.1.0-SNAPSHOT

-main clj

(-main & args)

add-shutdown-hook-consumer! clj

(add-shutdown-hook-consumer! consumer continue?)

Registers a shutdown hook to exit the consumer cleanly

consume-messages! clj

(consume-messages! topic group-id dispatcher-fn)

Creates Kafka Consumer and shutdown hook, and starts the consumer

consumer-config clj

(consumer-config topic group-id)

kafka-config clj

poll-and-loop! clj

(poll-and-loop! consumer processing-fn continue?)

Continuously fetches records every poll-ms, processes them and commits offset after each poll.

produce-message! clj

(produce-message! topic message)

Creates a Kafka Producer and writes message to topic by calling producer-fn

producer-config clj

(producer-config topic)

start-consumer! clj

(start-consumer! consumer processing-fn continue?)

Starts consumer loop to process events read from topic

start-consumer-thread! clj

(start-consumer-thread! topic group-id fn)

stop-and-close-consumer! clj

(stop-and-close-consumer! consumer continue?)

Stops the consumer polling loop and closes the consumer.

topic-config clj

(topic-config topic)