flink 新旧connector的区别

为什么需要新connector接口

// 为了兼容流批都是exactly-once 旧版专为流设计,不兼容批处理

写法区别