sunxiaojian commented on issue #180: URL: https://github.com/apache/rocketmq-connect/issues/180#issuecomment-1172016951
> > 问题二：exactly once问题尽量让系统来保证，尽量通过系统offset来保证，如果不满足可以对其进行改进 > > 问题三：对于顺序性保证的问题，如果系统不能保证需要对系统内进行优化，首先要系统保证，如果系统保证了是不是就不需要了加方法了？ > > 问题一我们以现在的RmqSourceRepicator为例，现在是实现不了自己维护位点的，WorkerSourceTask里面的producer发送成功了或者失败了都没有通知机制； 问题二和问题三都是系统实现的问题，但是增加这两个接口不影响系统实现，所以这两个问题不会成为connector实现精准一次投递和保序的绊脚石。 > 问题一： 实现不了自己维护位点的，是否是因为commit()和commitRecord()未进行调用？ 这个最近会做修正； 问题二： 可以对 commitRecord()进行丰富， 比如改成 commitRecord(ConnectRecord，RecordMetadata metadata) 来处理，metadata 为发送成功的信息描述， 如果metadata为空则任务是未发送成功的数据，作为错误数据处理；这样可以不新增方法，保证了SourceTask的简洁 @lizhiboo @odbozhou -- 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]
