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

EventHandler clj protocol

A handler that is called when at certain points in an events lifecycle. The passed processor contains all the configured dependencies.

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

ExtractPayloadFromRecord clj protocol

Allows implementors to consume the whole ConsumerRecord when extracting the payload

extract-from-record clj

(extract-from-record this record)

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

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