/flink-cdc-binlog2kafka

consume binlog based on flink cdc, and write to kafka