You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/07/01 03:45:18 UTC

[GitHub] [rocketmq-connect] lizhiboo commented on issue #180: Specify RocketMQ connect domain model

lizhiboo commented on issue #180:
URL: https://github.com/apache/rocketmq-connect/issues/180#issuecomment-1171899557

   > 
   
   @sunxiaojian 先来说一下引入这两个接口的背景，我需要自己维护offset，目前对于WorkerSourceTask发送异常的情况，是没有任何机制通知到SourceConnector的，如果要自己维护offset，是通过消费内部offset的消息来实现吗？
   对于exactly once的问题，是需要外部存储来记录，从而来保证刚好一次，如果需要实现刚好一次的逻辑，dismissFailedMsgs 和 customerFailedMsg同样可以访问这个外部存储实现；
   对于顺序性保证的问题，现在的实现同样不能保证顺序，如果需要实现保序，当发送失败时需要阻塞住，dismissFailedMsgs 和 customerFailedMsg也不会造成干扰，主要看这两个方法在WorkerSourceTask是什么时候被调用的。


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org