*

internal/authDB.go

@@ -122,7 +122,7 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 	}
 
 	// TODO
-	_, era := json.Marshal(customer.MessageRegistration)
+	value, era := json.Marshal(customer.MessageRegistration)
 	if era != nil {
 		return nil, era
 	}
@@ -131,12 +131,12 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 	s.logger.Printf("publication code %s to %s ...", customer.MessageRegistration.Code, customer.MessageRegistration.Email)
 
 	// Отправим уведомление о необходимости подтверждения
-	// err := s.kafkaWriter.WriteMessage([]byte(customer.Login), value)
-	// if err != nil {
-	// 	s.logger.Error(err)
+	err := s.kafkaWriter.WriteMessage([]byte(customer.Login), value)
+	if err != nil {
+		s.logger.Error(err)
 
-	// 	return nil, err
-	// }
+		return nil, err
+	}
 
 	//
 	s.logger.Printf("publication code %s to %s completed", customer.MessageRegistration.Code, customer.MessageRegistration.Email)