rewrite eventhubs component

Signed-off-by: Mukundan Sundararajan <msundar.ms@outlook.com>
dapr · Jan 3, 2022 · 8d1e3ec · 8d1e3ec
1 parent 5c9365b
commit 8d1e3ec
Show file tree

Hide file tree

Showing 4 changed files with 699 additions and 76 deletions.
diff --git a/authentication/azure/auth.go b/authentication/azure/auth.go
@@ -46,6 +46,12 @@ func NewEnvironmentSettings(resourceName string, values map[string]string) (Envi
 		es.Resource = azureEnv.ResourceIdentifiers.CosmosDB
 	case "servicebus":
 		es.Resource = azureEnv.ResourceIdentifiers.ServiceBus
+	case "eventhubs":
+		// Azure EventHubs (data plane)
+		// For documentation https://docs.microsoft.com/en-us/azure/event-hubs/authorize-access-azure-active-directory#overview
+		// The resource name to request a token is https://eventhubs.azure.net/, and it's the same for all clouds/tenants.
+		// Kafka connection does not factor in here.
+		es.Resource = "https://eventhubs.azure.net"
 	default:
 		return es, errors.New("invalid resource name: " + resourceName)
 	}