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

flike/kingbus
A distributed MySQL binlog storage system built on Raft
Language: Go
#binlog #distributed_systems #golang #mysql #mysql_binlog #raft #storage
Stars: 107 Issues: 0 Forks: 7
https://github.com/flike/kingbus