Liking cljdoc? Tell your friends :D
Clojure only.
kafka-event-processor.processor.component
EventHandlercljprotocol
A handler that is called when at certain points in an events lifecycle
A handler that is called when at certain points in an events lifecycle
on-completeclj
(on-complete this database cursor)A callback for when an event has finished processing with metadata about that event
A callback for when an event has finished processing with metadata about that event
IdempotentCheckcljprotocol
A handler that is called to define whether the message can be processed
A handler that is called to define whether the message can be processed
processable?clj
(processable? this database topic event-id)A callback to decide if an event should be processed
A callback to decide if an event should be processed
RewindCheckcljprotocol
A handler that is called to define whether the kafka topic needs rewinding
A handler that is called to define whether the kafka topic needs rewinding
rewind-required?clj
(rewind-required? this processor)A callback to decide if a rewind is required
A callback to decide if a rewind is required
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close