diff --git a/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/UserGroupCdcService.java b/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/UserGroupCdcService.java index d693c224..3964281d 100644 --- a/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/UserGroupCdcService.java +++ b/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/UserGroupCdcService.java @@ -47,7 +47,7 @@ @Slf4j @ApplicationScoped public class UserGroupCdcService { - private static final String OPERATION_NAME = "USER-GROUP-CDC-UserInfoUpdate"; + private static final String OPERATION_NAME = "USER-GROUP-CDC-sendUserGroupEvent"; private static final String COLLECTION_NAME = "userGroups"; private final TelemetryClient telemetryClient; @@ -118,7 +118,7 @@ private void initOrderStream(Boolean sendEventsEnabled) { this::consumerToSendScUserGroupEvent, failure -> { log.error("Error during subscribe collection, exception: {} , message: {}", failure.toString(), failure.getMessage()); - telemetryClient.trackEvent(EVENT_USER_GROUP_CDC_NAME, mapPropsForTrackEvent(TrackEventInput.builder().exception(failure.getClass().toString()).build()), Map.of(EVENTS_USER_INSTITUTION_FAILURE, 1D)); + telemetryClient.trackEvent(EVENT_USER_GROUP_CDC_NAME, mapPropsForTrackEvent(TrackEventInput.builder().exception(failure.getClass().toString()).build()), Map.of(EVENTS_USER_GROUP_FAILURE, 1D)); Quarkus.asyncExit(); }); } diff --git a/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/constant/CdcStartAtConstant.java b/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/constant/CdcStartAtConstant.java index b2688dfb..1f45eb86 100644 --- a/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/constant/CdcStartAtConstant.java +++ b/apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/constant/CdcStartAtConstant.java @@ -3,7 +3,7 @@ public class CdcStartAtConstant { - public static final String CDC_START_AT_PARTITION_KEY = "User"; + public static final String CDC_START_AT_PARTITION_KEY = "UserGroup"; public static final String CDC_START_AT_ROW_KEY = "0001"; public static final String CDC_START_AT_PROPERTY = "startAt";