diff --git a/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java b/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java index b277f08700..55717ffd4f 100644 --- a/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java +++ b/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java @@ -32,6 +32,7 @@ private void inputKafkaTopic(Request request) throws Exception { logger.info("UserDeletionBackgroundJobActor::inputKafkaTopic:: roles size:: " + roles.size()); User user = userService.getUserById(userId, request.getRequestContext()); String rootOrgId = user.getRootOrgId(); + String userName = user.getUserName(); List> suggestedUsersList = new ArrayList<>(); Map searchQueryMap = new HashMap<>(); @@ -110,6 +111,7 @@ private void inputKafkaTopic(Request request) throws Exception { Map eData = new HashMap<>(); eData.put(JsonKey.ORGANISATION_ID, rootOrgId); eData.put(JsonKey.USER_ID, userId); + eData.put(JsonKey.USERNAME, userName); eData.put(JsonKey.SUGGESTED_USERS, suggestedUsersList); eData.put(JsonKey.MANAGED_USERS, managedUsersList); eData.put(JsonKey.ACTION, JsonKey.DELETE_USER_ACTON);