The EnsureNamespace function silently ignored errors from GetNamespaces, masking connection/permission issues and potentially causing duplicate namespace creation attempts.

Changes

• Error flow restructure: Changed if err == nil to if err != nil with explicit handling. When namespace listing fails, proceed to creation (listing may fail due to permissions while creation succeeds). The subsequent CreateNamespace call surfaces genuine errors.

• Idempotent creation: Detect "already exists" errors from CreateNamespace and treat as success. Uses case-insensitive string matching for multiple error patterns since Pulsar admin client lacks typed errors:

  errMsg := strings.ToLower(err.Error())
  if strings.Contains(errMsg, "already exists") ||
      strings.Contains(errMsg, "alreadyexists") ||
      strings.Contains(errMsg, "409") ||
      strings.Contains(errMsg, "conflict") {
      return nil
  }

• Error context: Real errors now properly propagate with fmt.Errorf wrapping.

Before: Connection/permission errors during listing were ignored, errors from duplicate creation were returned.

After: Real errors surface appropriately, function is fully idempotent.

💬 We'd love your input! Share your thoughts on Copilot coding agent in our 2 minute survey.