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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
