java.lang.IllegalStateException: Illegal pop() with non-matching JdbcValuesSourceProcessingState

[coder-github578]

Below is the code for inserting the records

Uni txnInstance = sessionFactory.withTransaction((session, transaction) -> session.persist(eventEntity));
txnInstance.onFailure(this::logError)
.recoverWithNull()
.subscribe()
.with(this::logAction);

return Mono.just(exceptionEvent);

The records for insertion are coming from kafka streams and we have to first check whether record exists, If not then do insert. However sometimes we get the below error
java.lang.IllegalStateException: Illegal pop() with non-matching JdbcValuesSourceProcessingState

We also tried session.merge but that also resulted in the same error.

Any kind of guidance would be appreciated

[DavideD]

This error usually happens when the same session is accessed in parallel.