[SELC-5740] fix for change request

pagopa · Oct 16, 2024 · 1c97fda · 1c97fda
1 parent 0fa12f9
commit 1c97fda
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
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
@@ -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/...er-group-cdc/src/main/java/it/pagopa/selfcare/user/event/constant/CdcStartAtConstant.java b/...er-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";