为什么需要新connector接口// 为了兼容流批都是exactly-once 旧版专为流设计,不兼容批处理写法区别