kafka-event-processor.processor.protocols — b-social/kafka-event-processor 0.1.3

EventHandler clj protocol

A handler that is called when at certain points in an events lifecycle

extract-payload clj

(extract-payload this event)

A callback to transform the event into a suitable format for processing

on-complete clj

(on-complete this processor event event-context)

A callback for when an event has finished processing

on-event clj

(on-event this processor event event-context)

A callback for processing an event

processable? clj

(processable? this processor event event-context)

A callback to decide if an event should be processed

RewindCheck clj protocol

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