| page_type | languages | products | description | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
sample |
|
|
Create a Change Data Feed from Azure SQL or SQL Server using the Open Source tool Debezium |
Azure SQL Database and SQL Server Change Stream sample using Debezium. A change feed or change stream allow applications to access real-time data changes, using standard technologies and well-known API, to create modern applications using the full power of database like SQL Server.
Debezium make use of Change Data Capture, so it can be used with SQL Server on-premises and the whole Azure SQL family (https://azure.microsoft.com/en-us/products/azure-sql) (Azure SQL MI, Azure SQL DB, SQL Server on VM).
With Debezium and Azure SQL / SQL Server you can not only create more modern and reactive applications that handle data changes in near real time with a minium impact on the database, but you can also use it to implement your Hybrid IT strategy, still using On-Prem SQL Server but relying on Azure for all your computing needs, taking advantage of PaaS offerings like EventHubs and Azure Functions. This sample will show how to do that.
For those who want more details, Debezium uses Apache Kafka, which is not natively available on Azure as a PaaS offer. But luckily EventHubs offer almost 100% support, so we can use it instead of Kafka and make maintenance and scalability easier.
This step by step guide uses Wide World Importers sample database from here:
https://github.com/Microsoft/sql-server-samples/releases/tag/wide-world-importers-v1.0
Make sure you download the OLTP database if you want to follow this guide without having to change a thing. To restore the database on Azure SQL, you can use the scripts provided here: Restore Database in Azure SQL.
Debezium needs to query the database so a dedicated user is used throughout the sample. User has db_owner access to make the script simpler. In real world you may want to tighten security a bit more.
To create the login and user run the script 00-setup-database-user.sql from the sql folder (pertinent to the service or product you are using, Azure SQL or SQL Server / Azure SQL MI) on the database where you have restored Wide World Importers database.
Debezium uses Change Data Capture to capture all the changes done to selected tables.
In this samples only two tables are monitored:
- Sales.Orders
- Warehouse.StockItems
The script 01-enable-cdc.sql enable Change Data Capture on the aforementioned tables.
All data gathered by Change Data Capture will be send to Event Hubs, so create an Azure Event Hubs in your Azure Subscription. Using the Azure Cloud Shell Bash:
# Set vars
RESOURCE_GROUP=debezium
LOCATION=eastus
EVENTHUB_NAMESPACE=debezium
EVENTHUB_SCHEMA_HISTORY=schemahistory
# create group
az group create \
--name $RESOURCE_GROUP \
--location $LOCATION
# create eventhub namespace with kafka enabled
az eventhubs namespace create \
--name $EVENTHUB_NAMESPACE \
--resource-group $RESOURCE_GROUP \
--location $LOCATION \
--enable-kafka
# create eventhub for schema history
az eventhubs eventhub create \
--resource-group $RESOURCE_GROUP \
--namespace $EVENTHUB_NAMESPACE \
--name $EVENTHUB_SCHEMA_HISTORY \
--partition-count 1 \
--cleanup-policy Delete \
--retention-time-in-hours 168Later in the configuration process you'll need the EventHubs connection string, so grab it and store it somewhere:
RESOURCE_GROUP=debezium
EVENTHUB_NAMESPACE=debezium
az eventhubs namespace authorization-rule keys list \
--resource-group $RESOURCE_GROUP \
--namespace-name $EVENTHUB_NAMESPACE \
--name RootManageSharedAccessKey \
--query "primaryConnectionString" \
--output tsvIn order to run Debezium you have to install and configure Apache Kafka, Apache Zookeper and Kafka Connect. If you already know how to do that, or your already have a testing or development environment, well, perfect. Go and install Debezium SQL Server Connector: Installing a Debezium Connector.
If prefer a more lean and quick easy to start using Debezium, you can just use the Debezium Docker Image, that provides anything you need to run a test instance of Debezium. Just make sure you have Docker and Docker Compose installed. In the debezium/on-prem folder you can find all the scripts needed to run Debezium using Docker.
Docker Compose will use .env to get the environment variables values used in the .yaml configuration file. The provided .env.template file look like the following:
DEBEZIUM_VERSION=2.7
EVENTHUB_NAMESPACE=<eventhub_namespace>
EVENTHUB_CONNECTION_STRING=<eventhub_connection_string>Copy it and create a new .env file. Leave the version set to 2.7. Change the EVENTHUB_NAMESPACE to the EventHubs name you created before. Also set EVENTHUB_CONNECTION_STRING to hold the EventHubs connection string you got before. Make sure not to use any additional quotes or double quotes.
If you are just interested in testing Debezium you can safely skip this section and move to the next one to start Debezium. If you want to understand how to make Debezium work with Event Hubs, read on.
Debezium needs Apache Kafka to run, NOT Azure Event Hubs. Luckily for us, Azure Event Hubs exposes a Kafka-Compatible endpoint, so we can still enjoy Kafka with all the comfort of a PaaS offering. There are a few tweeks needed in order to make Debezium working with Azure Event Hubs.
First of all EventHubs requires authentication. This part is taken care from the configuration settings that looks like the following:
- *_SECURITY_PROTOCOL=SASL_SSL
- *_SASL_MECHANISM=PLAIN
- *_SASL_JAAS_CONFIG=[...]Documentation on EventHubs Kafka Authentication and Kafka Connect is available here:
Integrate Apache Kafka Connect support on Azure Event Hubs
Since we're running a Docker Image, we cannot really change the configuration file, but Debezium allows pass-through configurations:
There is additional caveat to keep in mind. EventHubs security uses the string $ConnectionString as username. In order to avoid to have Docker Compose to treat it as a variable instead, a double dollar sign $$ needs to be used:
Docker Compose Config File Variable Substitution
Two other options useful for running Debezium on Azure Event Hubs are the following:
- CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE=false
- CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE=trueThey control if the schema is sent with the data or not. Since the Azure Event Hubs only support values, as opposed to Apache Kafka, which everything is actually a key-value pair, the schema generation for the key section can be safely turned off. While this can also be done for the value part, it is not recommended as some data type are serialized in a Kafka-specific way and you need to know their "sematic" type in order to recreate the correct value.
Debezium SQL Server Connector Data Types
Here's a sample of a schema for a "create" (INSERT) event:
Debezium SQL Server Connector Create Event Sample
Debezium can now be started. If you're using the Docker Images you can just do this by running debezium/on-prem/start-debezium.ps1 (or the .sh file if you're on Linux/WSL)
Once the startup has finished, you'll see something like
[Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
you will see four topics (or EventHub to use the Azure EventHubs nomenclature):
RESOURCE_GROUP=debezium
EVENTHUB_NAMESPACE=debezium
az eventhubs eventhub list \
--resource-group $RESOURCE_GROUP \
--namespace-name $EVENTHUB_NAMESPACE \
--output tableand the result will show:
- debezium_configs
- debezium_offsets
- debezium_statuses
- schemahistory
to explore Azure Event Hubs is strongly suggest to download and use Service Bus Explorer
Now that Debezium is running, the SQL Server Connector (which is used both for connecting to Azure SQL or SQL Server) can be registered. Before doing that, make sure to specify the correct connection for your SQL Server instance in a file named sqlserver-connector-config.json. You can create one using the template file sqlserver-connector-config.json.template file.
Make sure to change the following properties to match your SQL Server configuration:
"database.hostname": "<sql_server_name>.database.windows.net",
"database.names": "<db_name>",
"database.user" : "<debezium_user_name>",
"database.password" : "<debezium_user_password>",You would need to replace <sql_server_name>, <db_name>, <debezium_user_name>, and <debezium_user_password> with proper values.
Also, make sure to change the following properties to match your Azure Event Hub configuration:
"schema.history.internal.kafka.bootstrap.servers": "<eventhub_namespace>.servicebus.windows.net:9093",
"schema.history.internal.kafka.topic": "<eventhub_schema_history>",
"schema.history.internal.consumer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$ConnectionString\" password=\"<eventhub_connectionstring>\";",
"schema.history.internal.producer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$ConnectionString\" password=\"<eventhub_connectionstring>\";",You would need to replace <eventhub_namespace>, <eventhub_schema_history>, and <eventhub_connectionstring> with proper values.
All the other values used are explained in detail here:
SQL Server Connector Configuration Values
Once the configuration file is set, just register that using debezium/on-prem/register-connector.ps1.
Depending on how big your tables are, it make take a while (more on this later). Once you see the following message:
Snapshot step 8 - Finalizing [io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource]
and no other errors or exception before that, you'll know that the SQL Server Connector is correctly running.
Now that Debezium is running and fully configured, you can generate a new Sales Order and insert, update and delete some data in the Stock table. You can use the following scripts:
./sql/.../02-create-new-sales-order.sql
./sql/.../03-modify-warehouse-stock.sqlAfter running the script you can use Service Bus Explorer or VS Code Event Hub Explorer to consume the stream of changes sent to Azure Event Hubs. You'll notice a new topic named wwi. That's where we instructed Debezium to send all the changes detected to the monitored tables.
One way to quickly react to the Change Stream data coming from Debezium is to use Azure Functions. A sample is available in folder azure-function. The easiest way to run the sample is to open it from VS Code or via Azure Function Core Tools, via func start. It will automatically recognize it as an Azure Function and download everything needed to run it.
Make sure you have a local.setting.json that looks like the provided template. Copy the Azure Event Hubs connection string you got at the beginning into the Debezium configuration option.
Start the function. As soon as the Azure Function runtime is running, the code will start to process the changes already available in EventHubs and you'll see something like this:
Event from Change Feed received:
- Object: Sales.Orders
- Operation: Insert
- Captured At: 2019-08-04T22:35:59.0100000Z
> OrderID = 73625
> CustomerID = 941
> SalespersonPersonID = 3
> PickedByPersonID =
> ContactPersonID = 3141
> BackorderOrderID =
> OrderDate = 8/4/2019 12:00:00 AM
> ExpectedDeliveryDate = 8/5/2019 12:00:00 AM
> CustomerPurchaseOrderNumber = 4923
> IsUndersupplyBackordered = False
> Comments = Auto-generated
> DeliveryInstructions = Unit 17, 1466 Deilami Road
> InternalComments =
> PickingCompletedWhen =
> LastEditedBy = 3
> LastEditedWhen = 8/4/2019 10:35:58 PM
Executed 'ProcessDebeziumPayload' (Succeeded, Id=ee9d1080-64ff-4039-83af-69c4b12fa85f)
Congratulations, you now have a working Change Stream from SQL Server. This opens up a whole new set of possibilities! Have fun!
If you're using Debezium with Azure SQL MI or Azure SQL DB, you may want to run Debezium on Azure. Sample script to run the Debezium container on Azure Container Instances are available in the debezium/azure folder.
More details on SQL Server and Event Hubs specific configuration here:
SQL Server Connector Configuration Values
If, after starting the Azure Function via func start you get the following error:
The listener for function 'ProcessDebeziumPayload' was unable to start. Microsoft.WindowsAzure.Storage: No connection could be made because the target machine actively refused it. System.Net.Http: No connection could be made because the target machine actively refused it. System.Private.CoreLib: No connection could be made because the target machine actively refused it.
you need to make sure that Azure Storage Emulator is installed and started.