Liking cljdoc? Tell your friends :D

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
sourceraw docstring

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
sourceraw docstring

Processorclj

source

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
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close