sunxiaojian opened a new pull request, #201:
URL: https://github.com/apache/rocketmq-connect/pull/201
1. 优化WorkerSourceTask 和 WorkerSinkTask， 将重复实现提取到父类； 将状态变更部分全部挪到
WorkerTask父类中，实现类只专注业务实现，不关注状态变更
2. Optimize commitRecord
优化commitRecord，允许用户自定义 offset 维护方式
3. offset保证提交有序
4. WorkerSourceTask增加topic检查和创建的功能，用于支持单任务多topic路由支持
5. worker增加线程超时配置
6. WorkerDirectTask 优化提交offset
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
