cb.cljbeat.ottla — com.chartbeat.cljbeat/ottla 0.9-SNAPSHOT

Top-level namespace where all public API functions live. See README for example usage.

-async-producer-loop clj

(-async-producer-loop prdcr handler)

-step-and-commit! clj multimethod

ManualCommittingOttlaMachine clj protocol

commit! clj

(commit! this cnsmr)

commit the current offsets, by default this happens after every step

OTTLA_CLI_OPTIONS clj

The options that are automagically included when you use defconsumer

OttlaMachine clj protocol

init clj

(init this cli-options)

Given a map of cli-options, inits the machine.

step clj

(step this msgs)

Given a list of msgs, updates the machine.

start clj

(start machine opts)

(start machine args cli-options)

Parses args and starts an OttlaMachine.

start-async-producer clj

(start-async-producer opts handler)

(start-async-producer args cli-options handler)

Handler is a function that converts a message from the channel into a kafka message. This function must return a map containing {:topic :key :value} or {:topic :partition :key :value} as per producer/send-and-flush-batch

start-producer clj

(start-producer opts)

(start-producer args cli-options)

parses args and returns a new producer