in src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractUpsertCommandHandler.java [45:53]
public EntityId upsert(Request<T> input) {
Map<String, Object> entityMap = entityConverter.entityToMap(input.getPayload());
Object entityId = entityMap.remove(tableDataProvider.pkColumnName());
if (entityId == null) {
return createCommandHandler.save(input);
}
updateCommandHandler.update(input);
return new EntityId(UUID.fromString(entityId.toString()));
}