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/06/23 02:58:46 UTC

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

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

   imo, the source task provides the void commitRecord(SourceRecord record, RecordOffset recordOffset) method. If the source task implementation wants to maintain the offset itself, it implements the commit method. If it is not implemented, the WorkerSourceTask will maintain the offset. Is it possible to solve this problem?
   The sink task is also similar, and the corresponding api has been provided in the api
   flush(Map<RecordPartition, RecordOffset> currentOffsets)
   If the site that fails to submit can be flushed to remove the corresponding partition, WorkerSinkTask can not submit the site of the failed partition.


-- 
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