
Build a near real-time streaming data pipeline using Confluent Kafka on Azure, connecting Datagen source to Cosmos DB via Azure Function Sync Connector, and visualize analytics with Power BI.
Build a real-time data streaming pipeline by creating a Confluent cluster on Azure, generating an API key, and creating a Kafka topic named orders to host data.
Create a datagen source connector in Confluent to push order data into a Confluent topic, configuring API keys, JSON format, and the order schema for real-time streaming.
Create an Azure function app in Visual Studio Code using the Azure extension, selecting legacy consumption plan, West US two, and Python 3.12, then configure storage and application insights.
Create and deploy an Azure function in the function app using Visual Studio Code with an HTTP trigger, test it, deploy to Azure, and monitor logs, keys, and invocations.
Update an Azure function in Python to log with logging.info and parse incoming Confluent Kafka messages. From the message, extract the nested value and prepare for Cosmos DB insertion.
Create a real-time data pipeline by connecting Confluent topics to an Azure Function Sink connector, pushing data to Azure Cosmos DB for live analytics with Power BI or Tableau.
Create an Azure Cosmos DB account and orders container with a NoSQL database and partition key id. Push real-time data from Confluent Kafka to Cosmos DB using an Azure Function.
Update the Azure function to insert records into Cosmos DB using Python, enabling end-to-end real-time data flow from Confluent to Cosmos DB for Power BI analytics.
Visualize a real-time data streaming pipeline from Confluent Kafka to Azure Cosmos DB and Power BI, demonstrating end-to-end flow and live metrics like top states by order units.
Verify the end-to-end data pipeline from the data source connector through Confluent topic, Azure function sync connector, Cosmos DB, to Power BI, and validate with logs and queries.
Review the end-to-end near real-time data pipeline built with Confluent Cloud, from data source connectors to Azure Functions and Cosmos DB, with Power BI for analytics.
In this hands-on course, participants will follow along step-by-step to build a real-time streaming data pipeline that sends data from Confluent Kafka using Azure Functions Sink connector to Azure Functions to Azure Cosmos DB and finally creating operational report using Power BI. This course is designed to provide practical, real-world skills by walking through each component of the architecture, ensuring that learners not only understand the concepts but also apply them directly in a cloud environment.
On the Azure Cloud Platform side, participants will gain experience working with several important services, including Azure Functions, Cosmos No SQL DB and Power BI. The participant will also be exposed to logging, trouble shooting, monitoring and configuring these Azure Cloud Platform services. These services are essential for building secure, scalable, and reliable applications in the cloud.
On the Confluent Kafka side, learners will set up a fully managed Kafka cluster, create topics for message streaming, & configure a fully managed Source Connector to simulate real-world data ingestion, also configure fully managed Azure Functions Sink connector. This gives participants valuable exposure to enterprise-grade Kafka infrastructure without the overhead of managing the platform themselves.
By the end of this course, participants will have built a working, scalable pipeline, gained insights into cloud-native architectures, and acquired hands-on experience that can be directly applied to real-world projects or professional roles.
This course is suitable for budding Cloud Engineers, mid level Data Engineers, Product Owners, Product Mangers, Scrum Masters and Technology Leaders looking to get a hands-on experience of building a Real time Streaming Data Pipeline.