Hello,
The way DefaultPersistor#setNextSequence handles race condition to assign a first sequence number does not work with PostgreSQL. The same connection is re-used for a recursive call when an indexViolation has been detected. This is not allowed by PostgreSQL and will lead to the following error :
ERROR: current transaction is aborted, commands ignored until end of transaction block
As a result, scheduling two executions at the same time (on the same topic) could fail for one execution.
Hello,
The way
DefaultPersistor#setNextSequencehandles race condition to assign a first sequence number does not work with PostgreSQL. The same connection is re-used for a recursive call when anindexViolationhas been detected. This is not allowed by PostgreSQL and will lead to the following error :As a result, scheduling two executions at the same time (on the same topic) could fail for one execution.