Inspiration

One of our customers needed EventHub for kafka as a broker service and their platform is Python. Since Azure Samples did not have specific example for Python we developed the solution and contributed to Azure sample repository along with customer code base.

What it does

Relies on Azure.Identity for OAUTH token, can authenticate and connect with Azure EventHubs using Kafka protocol as well as non-kafka protocol

How we built it

With reference for other languages and some reading into Azure.Identity as well as Confluent-Kafka, we implemented the auth pattern.

Challenges we ran into

Nothing specific to Identity

Accomplishments that we're proud of

We solved our customer's cross cloud brokerage solution issue along with same code that supports ClientCredential flow (aws) and ManagedIdentity flow (azure) without a code change

What we learned

We learned a great deal about the DefaultAzureCredential implementation which looks for chained auth mechanism configured. How it works without a code change in each of the situation. We also learned a great deal with EventHubs, Kafka

What's next for Azure EventHub for kafka - OAUTH Python

Contribute to Azure Samples

Built With

Share this project:

Updates