feat: add email field to user creation and improve notification sending

src/main/java/com/security/events/notification/CreatedUserEvent.java

@@ -6,6 +6,7 @@ public record CreatedUserEvent(
         String lastName,
         String dni,
         String phone,
+        String email,
         String profileImageUrl
 ) {
 }

src/main/java/com/security/services/Impl/AuthServiceImpl.java

@@ -196,6 +196,7 @@ public LoginResponseDTO registerUser(RegisterRequestDto registerRequestDto) {
                 registerRequestDto.lastName(),
                 registerRequestDto.dni(),
                 registerRequestDto.phone(),
+                registerRequestDto.email(),
                 null
         );
 

src/main/java/com/security/services/Impl/NotificationServiceImpl.java

@@ -4,9 +4,12 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.kafka.support.SendResult;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.concurrent.CompletableFuture;
+
 @Service
 @Slf4j
 @RequiredArgsConstructor
@@ -15,10 +18,26 @@ public class NotificationServiceImpl {
 
     @Transactional
     public void sendNotification(String message) {
-        log.info("Antes de publicar el mensaje");
-        NotificationEvent event = new NotificationEvent(message);
-        kafkaTemplate.send("user-created-event-topic", event);
-        log.info("Mensaje enviado {}", event);
-    }
+        try {
+            log.info("Enviando notificación: {}", message);
+            NotificationEvent event = new NotificationEvent(message);
+
+            // Envío asíncrono con callback
+            CompletableFuture<SendResult<String, Object>> future =
+                    kafkaTemplate.send("user-created-event-topic", event);
 
-}
+            future.whenComplete((result, exception) -> {
+                if (exception == null) {
+                    log.info("✅ Notificación enviada exitosamente: offset={}",
+                            result.getRecordMetadata().offset());
+                } else {
+                    log.error("❌ Error enviando notificación", exception);
+                }
+            });
+
+        } catch (Exception e) {
+            log.error("❌ Error en sendNotification", e);
+            throw e;
+        }
+    }
+}

src/main/java/com/security/services/oauth2/CustomOAuth2UserService.java

@@ -146,6 +146,7 @@ private void publishUserCreatedEvent(UserEntity user, OAuth2UserInfo userInfo) {
                 userInfo.getLastName(),
                 null,
                 null,
+                userInfo.getEmail(),
                 userInfo.getProfileImageUrl()
         );
 
@@ -160,6 +161,7 @@ private void publishUserUpdateEvent(UserEntity user, OAuth2UserInfo userInfo) {
                 userInfo.getLastName(),
                 null,
                 null,
+                userInfo.getEmail(),
                 userInfo.getProfileImageUrl()
         );