sunxiaojian commented on issue #85: URL: https://github.com/apache/rocketmq-connect/issues/85#issuecomment-1098675922
问题一描述： 版本 0.1.1 api的定义  版本0.1.2 api定义  差异点： 0.1.1版本是 start是必须实现的，0.1.2版本是init是必须实现的， 问题描述：如果定位是init是初始化配置，那start应该是初始化offset等逻辑的；现在start是不必实现的，对于不了解api的插件扩展者来说可能就不会实现了，这样可能会把初始化客户端和jdbc连接的操作在init里面全部实现了，但是由于在WorkerSinkTask(WorkerSourceTask一样)中的调用顺序是下面如图，在init里面是无法拿到父类SourceTask和SinkTask中的 context 变量的，由于调用顺序的原因，这个值在init的时候应该是空，因为调用顺序造成在init使用这个变量无法实现，这样可能就无法拿到offset等信息，所以实现start方法就成为了必须，但是父类又实现了这个start方法赋值了context，本来是必须要实现的现在做成了可实现可不实现，所以就感觉比较矛盾，所以建议还是0.1.1 api 会比较好一点  问题二描述： pause和 resume 是不是就不要对客户开放了，插件的编写只需要了解获取数据和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]
