Add oauth2 to the provider

--- *Motivation* Add oauth2 authentication can be constructed by name.
apache · Jul 31, 2020 · 6dad53c · 6dad53c
1 parent 975eb37
commit 6dad53c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pulsar/internal/auth/provider.go b/pulsar/internal/auth/provider.go
@@ -63,6 +63,10 @@ func NewProvider(name string, params string) (Provider, error) {
 	case "athenz", "org.apache.pulsar.client.impl.auth.AuthenticationAthenz":
 		return NewAuthenticationAthenzWithParams(m)
 
+	case "oauth2", "org.apache.pulsar.client.impl.auth.oauth2.AuthenticationOAuth2":
+		return NewAuthenticationOAuth2WithParams(m)
+
+
 	default:
 		return nil, errors.New(fmt.Sprintf("invalid auth provider '%s'", name))
 	}