(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 builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |