sunxiaojian opened a new pull request, #248: URL: https://github.com/apache/rocketmq-connect/pull/248
本次优化点： - [ 1.] 优化WorkerSourceTask 增加 pause 和 resume的功能，提供source task 状态上报能力 - [ 2.] 优化WorkerSinkTask 并将 Rocketmq Consumer 替换成DefaultLitePullConsumer, 以使用 pause 、resume 及seek 功能，优化commit 提交流程，提供sink task状态上报能力 - [ 3.] 优化WorkerConnector, 增加 pause 和 resume 维护功能，提供connector 状态上报能力 - [ 4.] 增加 StateManagementService 状态管理服务，帮助缓存和向集群传输connector 和 task 任务的状态，并用于rest api状态透出 - [ 5.] 优化ConfigManagementServiceImpl，将异步每次发送全量配置改为每次只发送变更connector，为了解决配置任务过多而触发的消息body的限制，每次任务的变更以监听的消息为准 - [ 6.] 优化Worker增加维护connector的线程池，优化graceful的关闭机制 - [ 7.] 优化AbstractConnectController 添加接口供rest api使用 - [ 8.] 标准化rest api ，javalin 升级到>4.6 ，规范了api返回的数据格式，标准化了url 以上为本次优化点，有时间可以帮忙review一下 @odbozhou @duhenglucky -- 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]
