kafka-event-processor.processor.protocols
EventHandler
protocol
A handler that is called when at certain points in an events lifecycle. The passed processor contains all the configured dependencies.
members
extract-payload
(extract-payload this event)A callback to transform the event into a suitable format for processing
on-complete
(on-complete this processor event event-context)A callback for when an event has finished processing
on-event
(on-event this processor event event-context)A callback for processing an event
processable?
(processable? this processor event event-context)A callback to decide if an event should be processed
ExtractPayloadFromRecord
protocol
Allows implementors to consume the whole ConsumerRecord when extracting the payload
members
extract-from-record
(extract-from-record this record)A callback to transform the event record into a suitable format for processing
RewindCheck
protocol
A handler that is called to define whether the kafka topic needs rewinding
members
rewind-required?
(rewind-required? this processor)A callback to decide if a rewind is required