In nuxeo-importer-queues the producer commits the transaction every batchSize nodes. If the transaction is rolled back, every node of that chunk is rolled back accordingly.
A replay mecanism should allow in that case to replay every none failed node.
Two possible strategies :
- replay every node in a isolated transaction
- mark every failing node and replay only those who don't fail