kotr.kafka.client — clj-ksql 0.0.22

as-json-response clj

(as-json-response client topic-name total)

consume clj

(consume client topic-config callback)

consume-state-atom clj

convert-stream-to-avro-schema clj

(convert-stream-to-avro-schema stream-schema)

count-topic-row clj

(count-topic-row client topic-name)

delete-topics clj

(delete-topics client topics-name)

get-keyvals clj

(get-keyvals client topic-config)

(get-keyvals client 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 client topic-config)

(get-records client topic-config polling-interval-ms)

Takes a topic config, consumes from a Kafka topic, and returns a seq of maps.

init-context clj

(init-context)

(init-context m)

invoke clj multimethod

ksql clj

(ksql client ksql-str)

ksql-batch clj

(ksql-batch client ksql-coll-str)

list-topics clj

(list-topics client)

Returns a list of Kafka topics.

print-topic-async clj

(print-topic-async client topic-name total callback)

publish clj

(publish context topic-config value)

(publish context topic-config key value)

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

query clj

(query client query-str total)

query-async clj

(query-async client query-str callback)

stop-query clj

(stop-query client query-str)

topic-config-for-data clj

(topic-config-for-data client stream-name)

(topic-config-for-data client topic-name schema)

topic-config-for-metadata clj

(topic-config-for-metadata topic-name)

topic-exists? clj

(topic-exists? client topic-config)

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

topic-formater clj multimethod

topic-formatter-impl clj

(topic-formatter-impl w)

validate-stream-name clj

(validate-stream-name client stream-name)

validate-topic-name clj

(validate-topic-name client topic-name)