diff --git a/internal/workers/queueUpdater/queue_updater.go b/internal/workers/queueUpdater/queue_updater.go
index 9c85e58..e010e10 100644
--- a/internal/workers/queueUpdater/queue_updater.go
+++ b/internal/workers/queueUpdater/queue_updater.go
@@ -129,6 +129,10 @@ func (wc *QueueUpdater) processMessages(ctx context.Context, message models.Kafk
 		}
 
 	case models.UserCreate:
+		if message.AuthCode == nil {
+			return nil
+		}
+
 		token, err := wc.methods.CreateUserFromWebHook(ctx, message.AccountID, *message.AuthCode)
 		if err != nil {
 			wc.logger.Error("error creating user from webhook request", zap.Error(err))