Nice article! Thank Mariusz Michałowski!

Thanks for the article, it will save me a lot of time next week! 😅 I have some concerns. 1/ For the createProcessTicker method: try { for (const record of records) { await processRecord(record); await cursorRepo.setPosition(record.id); processedRecords++; } } catch (error) { logger.error('Could not process record', { processName, record, error, }); } finally { await cursorRepo.unlockCursor(); } Should error be forwarded in the catch block? Otherwise, the cursor process won't terminate if failed to process a record. 2/ For this termination flow } catch (error) { logger.critical('Terminating server: cursor process error', { processName: props.processName, error, }); // we use structured logging await lifecycle.close(); process.exit(1); } When a node is terminated and the cursor lock is released, will the terminated process propagate to the remaining nodes? I guess, there will be the scenario that container managers (CR, K8S) keep initialize new nodes to replace terminated nodes until the error is fixed.