WaterSlide is a streaming event-at-a-time architecture for processing metadata. It is designed to take in a set of streaming events from multiple sources, process them through a set of modules ("kids"), and return meaningful outputs.
Other
113
stars
40
forks
source link
functionality improvements to kafka_out and groupevents kids #33
kafka_out - added a recover and retransmission option when kafka fails to deliver after buffering
groupevents - added another triggering condition to dump stored events on a specific key
kafka_out - added a recover and retransmission option when kafka fails to deliver after buffering groupevents - added another triggering condition to dump stored events on a specific key