bytewatch/dolphinbeat
An application that pulls MySQL binlog, parses binlog and pushs incremental update data into different sinks, for example, kafka.
Language: Go
#binlog #change_data_capture #pipeline #stream_processing
Stars: 107 Issues: 0 Forks: 7
https://github.com/bytewatch/dolphinbeat

ElAlev/Wayeb
Wayeb is a Complex Event Processing and Forecasting (CEP/F) engine written in Scala.
Language: Scala
#automata #cep #complex_event_forecasting #complex_event_processing #forecasting #markov_models #regular_expression #scala #stream_processing #symbolic_automata
Stars: 106 Issues: 1 Forks: 4
https://github.com/ElAlev/Wayeb

ArroyoSystems/arroyo
Arroyo is a distributed stream processing engine written in Rust
Language: Rust
#data #dev_tools #infrastructure #kafka #rust #sql #stream_processing
Stars: 294 Issues: 1 Forks: 5
https://github.com/ArroyoSystems/arroyo