Sink层的Connector进行了重要升级。
包括:
- 废弃BizRetryException异常,统一回归采用抛出BizException异常;
- 增加通过BizUtils.getBizMessage()方法,在Source、App、Sink层中获取当前交易BizMessage的能力;
- 增加service类型的Sink Connector,支持Spring容器类的挂接,不再支持sink-bean、bean类型的Sink Connector(connector项下type为sink-bean、bean);
- 增加http类型的Sink Connector,支持HTTP接口的对接;
- 增加ByteProcessInterface接口类,把byte[] process(byte[])方法作为Sink Connector最常用的处理接口实现,该方法会被default类型的Sink服务所调用。