canal采集binlog入kafka，flink实时处理数据并sink到phoenix中

基于官方otter，添加自己使用过程中的小需求；