Should be fairly doable using binlog-based producer https://github.com/go-mysql-org/go-mysql.