How can I setup output binding to EventHub?

[Arkatufus]

Hi,
I'm trying to use Kafka output binding to connect to EventHub from Azure Functions, I tried the one described in the sample directory:

[Kafka(
  brokerList:"EVENT_HUB_FQN", 
  topic:"MY_TOPIC",
  Username = "$ConnectionString",
  Password = "EVENT_HUB_CONNECTION_STRING",
  Protocol = BrokerProtocol.SaslSsl,
  AuthenticationMode = BrokerAuthenticationMode.Plain)] IAsyncCollector<KafkaEventData<byte[]>> retryQueue

but i'm getting this error:

Failed to delivery message to my-topic / -1 / -1001. Reason: Broker: Topic authorization failed. Full Error: Broker: Topic authorization failed

From the EventHub page, it looks like I need to add this jaas attribute to the kafka consumer:

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";

Is there a way to do output binding without having to use a ca cert or to inject the attribute into the KafkaAttribute?

EDIT:
Turns out it was all my own fault, I tried to connect to Event Hub using a connection string that only has a listen rights.
Sorry for all the trouble.

[TsuyoshiUshio]

Hi @Arkatufus
Your sample looks good. Probably it might be an issue of the configuration.

• brokerList: {YOUR_EVENT_HUBS_NAMESPACE}.servicebus.windows.net:9093
• topic: EventHub not EventHubs namespace
• Password: Connection String of EventHubs namespace not EventHub

Could you check these point? I can send message by this sample.

https://github.com/TsuyoshiUshio/KafkaTemplateSamples/tree/eventHubs/CSharp/Company