
2/4/2021 · Angela Chu
What this post added
This post demonstrates how to configure Azure Databricks to interact with Confluent Cloud for real-time data pipelines. It covers setting up Confluent Cloud (Kafka cluster, Schema Registry, Datagen Source connector) and Azure Databricks (workspace, cluster, libraries). The core technical contribution is the Python code for Spark ReadStream to consume Avro data from Confluent Cloud, parse it using Schema Registry, and store it on Azure Data Lake Storage (ADLS) in Delta Lake.