(as-of value stuff-to-do)
(check-kafka-produced-errors topic)
(check-kafka-produced-messages topic)
(clear-produced-messages! world)
(coercion-error? exception-info)
(http-response route)
(http-responses route)
(init! system-map world)
setup components and store them in the world
setup components and store them in the world
(kafka-message-arrived! topic message world)
(kafka-produce! topic message world)
(kafka-try-consume! topic message world)
(kafka-try-produce! topic message world)
(message-arrived! topic message world)
(mock-kafka-client & args)
(mock-kafka-producer & args)
(produce! topic message world)
(produced-errors topic)
(produced-messages topic)
(random-uuid)
(request-arrived! route world)
(request-arrived! route {:keys [path-params body supress-errors]} world)
(schema-error? exception-info)
(throws-ex m)
(try-consume! topic message world)
Try to consume message and, if any error is thrown while consuming, add the error to world in path [:consumption-errors <topic>]
Try to consume message and, if any error is thrown while consuming, add the error to world in path [:consumption-errors <topic>]
(try-produce! topic message world)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close