uses mysql binlogstream to monitor mysal table changes and update elasticsearch indices