*

internal/transport/grpc/grpc.go

@@ -112,6 +112,9 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 		return nil, eru
 	}
 
+	//
+	log.Printf("send code %s to %s ...", user.msg.Code, user.msg.Email)
+
 	//
 	err := s.kafkaWriter.WriteMessage([]byte(user.Login), value)
 	if err != nil {
@@ -120,9 +123,12 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 		return nil, err
 	}
 
+	//
+	log.Printf("send code %s to %s completed", user.msg.Code, user.msg.Email)
+
 	return &api.RegistrationResponse{
-		Code:  code,
-		Email: req.GetEmail(),
+		Code:  user.msg.Code,
+		Email: user.msg.Email,
 	}, nil
 }