data-audit/data-audit-common-service/src/main/java/org/kie/kogito/app/audit/kafka/ProcessInstanceDataEventDeserializer.java [33:41]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public ProcessInstanceDataEvent<?> deserialize(String topic, byte[] data) {
        try {
            return JsonUtils.getObjectMapper().readValue(new String(data), ProcessInstanceDataEvent.class);
        } catch (JsonProcessingException e) {
            LOGGER.error("not possible to deserialize ProcessInstanceDataEvent data {}", new String(data), e);
            throw new IllegalArgumentException("not possible to deserialize data");
        }

    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



data-index/data-index-service/data-index-service-common/src/main/java/org/kie/kogito/index/service/messaging/ProcessInstanceDataEventDeserializer.java [33:41]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public ProcessInstanceDataEvent<?> deserialize(String topic, byte[] data) {
        try {
            return JsonUtils.getObjectMapper().readValue(new String(data), ProcessInstanceDataEvent.class);
        } catch (JsonProcessingException e) {
            LOGGER.error("not possible to deserialize ProcessInstanceDataEvent data {}", new String(data), e);
            throw new IllegalArgumentException("not possible to deserialize data");
        }

    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -