Failed to start EPH for ... : link detached, reason: *Error{Condition: amqp:unauthorized-access, Description: Unauthorized access. 'Listen' claim(s) are required to perform this operation. Resource:

[uabhishek71]

Hi ,

I am using aad.NewJWTProvider() method to get token to access data from Azure Event hub , instead of using aad.JWTProviderWithEnvironmentVars() in aad.NewJWTProvider(aad.JWTProviderWithEnvironmentVars()) I have created my own method in which I am assigning config.tenantID , client ID and client secret directly instead of assigning it from environment variables , below is the method.

func SetJWTProvider() aad.JWTProviderOption {
return func(config *aad.TokenProviderConfiguration) error {
config.TenantID = "e91f4e68-e9aa-45fd-b665-f2ab1e5739fb"
config.ClientID = "71c2a438-a7ee-442b-9a6f-8c8063918ecc"
config.ClientSecret = ".33lMCgfAAsDFDxo_f6r4A]kzaXnmfg@"
// config.CertificatePath = os.Getenv("AZURE_CERTIFICATE_PATH")
// config.CertificatePassword = os.Getenv("AZURE_CERTIFICATE_PASSWORD")

	if config.Env == nil {
		env, err := azureEnvFromEnvironment()
		if err != nil {
			return err
		}
		config.Env = env
	}
	return nil
}

}
while using this I am getting below error , it seems that I am not able to authorize my request to pull data from Azure event hub.

Failed to start EPH for Event hub i***** : link detached, reason: *Error{Condition: amqp:unauthorized-access, Description: Unauthorized access. 'Listen' claim(s) are required to perform this operation. Resource: '*****'. TrackingId:8****_G7, SystemTracker:gateway5, Timestamp:2019-11-08T09:27:19, Info: map[]}