-
Notifications
You must be signed in to change notification settings - Fork 791
DRAFT: Change Data Capture documentation #11464
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: development
Are you sure you want to change the base?
Changes from all commits
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,64 @@ | ||
| --- | ||
| title: "Change Data Capture" | ||
| url: /refguide/change-data-capture/ | ||
| weight: 45 | ||
| description: "Describes Change Data Capture (CDC) services in Studio Pro, which publish domain model entity changes as Kafka streams for data warehouse and analytics pipelines." | ||
| --- | ||
|
|
||
| ## Introduction | ||
|
|
||
| Change Data Capture (CDC) lets you stream domain model data out of a Mendix app in near real time. When objects in a tracked entity are created, updated, or deleted, the Mendix runtime captures those changes and publishes them as events to a Kafka topic. Downstream systems — such as data warehouses or analytics pipelines — can then consume the stream without polling the Mendix database. | ||
|
Check failure on line 10 in content/en/docs/refguide/modeling/integration/change-data-capture/_index.md
|
||
|
|
||
| CDC is intended for developers who need to move Mendix domain model data to external data stores, such as a data warehouse, data lake, or blob storage. | ||
|
|
||
| ## How It Works | ||
|
|
||
| A CDC service document in Studio Pro defines which entities the runtime should track. On deployment, each tracked entity gets its own Kafka topic. Every time a committed object change occurs — create, update, or delete — the runtime publishes an event to the corresponding topic. | ||
|
Check failure on line 16 in content/en/docs/refguide/modeling/integration/change-data-capture/_index.md
|
||
|
|
||
| The Kafka broker is either the [Mendix Event Broker](/appstore/services/event-broker/) or a Bring Your Own Kafka (BYOK) cluster. For details on configuring BYOK, see the [Mendix Event Broker](/appstore/services/event-broker/) page. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. In case they want to BYOK, then they need a schema to parse the message. This is available in the Async API. |
||
|
|
||
| To move the streamed data to a destination such as Azure Blob Storage or AWS S3, you configure an [Event Broker Bridge](/appstore/services/event-broker/#manage-mx-broker-bridge) separately in the Event Broker Manager after deployment. | ||
|
|
||
| ## Prerequisites | ||
|
|
||
| * A [Mendix Event Broker](/appstore/services/event-broker/) license, or a BYOK Kafka cluster configured as described in [Mendix Event Broker](/appstore/services/event-broker/). | ||
| * An [Event Broker Bridge](/appstore/services/event-broker/#manage-mx-broker-bridge) configured in the Event Broker Manager if you want to route CDC events to external storage. | ||
|
|
||
| ## Setting Up Change Data Capture | ||
|
|
||
| 1. In Studio Pro, right-click a module in the App Explorer and choose **Add other** > **Change data capture service**. | ||
| 2. Configure the entities to track and their exposed names. See [Published CDC Services](/refguide/published-cdc-services/) for details. | ||
| 3. Deploy the app. The runtime creates Kafka topics for each tracked entity automatically. | ||
| 4. In the [Event Broker Manager](https://broker.mendix.com/), configure an [Event Broker Bridge](/appstore/services/event-broker/#manage-mx-broker-bridge) to route CDC events to your destination. | ||
|
|
||
| ## Runtime Configuration {#runtime-configuration} | ||
|
|
||
| CDC requires runtime settings to connect to a Kafka broker. In Studio Pro, open **App** > **Settings**, go to the **Configurations** tab, select or create a configuration, and open the **Custom** tab to add the settings below. For deployed environments, set these via your environment's custom runtime settings. | ||
|
|
||
| {{< figure src="/attachments/refguide/modeling/integration/change-data-capture/cdc-custom-configuration.png" alt="Edit Configuration dialog in Studio Pro showing the Custom tab with Kafka.BootstrapServers set to an IP address and port" >}} | ||
|
|
||
| ### Running Locally {#local-configuration} | ||
|
|
||
| When running the app locally, only the bootstrap server address is required: | ||
|
|
||
| | Name | Description | Default Value | | ||
| | --- | --- | --- | | ||
| | `Kafka.BootstrapServers` | The address of the Kafka broker, in the format `host:port`. | | | ||
|
|
||
| ### Bring Your Own Kafka (BYOK) {#byok-configuration} | ||
|
|
||
| When connecting to a BYOK Kafka cluster, provide the bootstrap server address and credentials for authentication. The supported authentication method is SASL/SCRAM-SHA-512. | ||
|
|
||
| | Name | Description | Default Value | | ||
| | --- | --- | --- | | ||
| | `Kafka.BootstrapServers` | The address of the Kafka broker, in the format `host:port`. | | | ||
| | `Kafka.Username` | The username for SASL/SCRAM-SHA-512 authentication with the Kafka cluster. | | | ||
| | `Kafka.Password` | The password for SASL/SCRAM-SHA-512 authentication with the Kafka cluster. | | | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. These are the complete list of our Runtime configuration, added for CDC document: The The leader election is optional but available for multi instances. I think it worth to mention it incase the user want to configure it. |
||
|
|
||
| For details on setting up a BYOK cluster with the Mendix Event Broker, see [Mendix Event Broker](/appstore/services/event-broker/). | ||
|
|
||
| ## Read More | ||
|
|
||
| * [Published CDC Services](/refguide/published-cdc-services/) | ||
| * [Mendix Event Broker](/appstore/services/event-broker/) | ||
| * [Event Broker Bridges](/appstore/services/event-broker/#manage-mx-broker-bridge) | ||
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| --- | ||
| title: "Published CDC Services" | ||
| url: /refguide/published-cdc-services/ | ||
| weight: 10 | ||
| description: "Describes how to configure a Published CDC Service document in Studio Pro to stream entity changes to Kafka topics." | ||
| --- | ||
|
|
||
| ## Introduction | ||
|
|
||
| A Published CDC Service document defines the entities whose object changes the Mendix runtime tracks and publishes as Kafka events. Each tracked entity produces a stream of create, update, and delete events on its own Kafka topic. | ||
|
|
||
| {{% alert color="warning" %}} | ||
| Change Data Capture is a beta feature in Mendix 11.12. Its behavior and configuration options may change in future releases. | ||
| {{% /alert %}} | ||
|
|
||
| ## Creating a Published CDC Service {#create} | ||
|
|
||
| To create a published CDC service, right-click a module in the App Explorer and choose **Add other** > **Change data capture service**. Studio Pro adds the document to that module for logical grouping, but the service operates at app level. | ||
|
|
||
| You can have multiple CDC service documents in an app — for example, to group entities by domain area or team ownership. | ||
|
Check failure on line 20 in content/en/docs/refguide/modeling/integration/change-data-capture/published-cdc-services.md
|
||
|
|
||
| ## General {#general} | ||
|
|
||
| ### Service Name {#service-name} | ||
|
|
||
| The service name uniquely identifies the CDC service within the app. It is used as part of the Kafka topic name. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
We should remove this, the topic does not include the service name
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. The service name must be unique within the app, however, it is not user as part of the topic name. |
||
|
|
||
| ### Description {#description} | ||
|
|
||
| An optional description for the CDC service. | ||
|
|
||
| ## Entities to Track {#entities} | ||
|
|
||
| The **Entities to track** table lists the entities whose object changes are published to Kafka. | ||
|
|
||
| {{< figure src="/attachments/refguide/modeling/integration/change-data-capture/published-cdc-service.png" alt="Published CDC Service document showing the Entities to track table with columns for Exposed name, Modification, Revision, and Topic" >}} | ||
|
|
||
| Use the toolbar to manage tracked entities: | ||
|
|
||
| * **+ Add** — add an entity from the domain model | ||
|
Check failure on line 40 in content/en/docs/refguide/modeling/integration/change-data-capture/published-cdc-services.md
|
||
| * **Remove** — stop tracking a selected entity | ||
|
Check failure on line 41 in content/en/docs/refguide/modeling/integration/change-data-capture/published-cdc-services.md
|
||
| * **Accept changes** — lock in the current revision numbers after reviewing modifications (see [Revisions](#revisions)) | ||
|
Check failure on line 42 in content/en/docs/refguide/modeling/integration/change-data-capture/published-cdc-services.md
|
||
|
|
||
| Each row in the table has the following columns: | ||
|
|
||
| | Column | Description | | ||
| | --- | --- | | ||
| | **Entities** | The domain model entity being tracked. Expand the row to view and select individual attributes and associations. | | ||
| | **Exposed name** | The name used for this entity in the Kafka topic and event payload. Defaults to the entity name. | | ||
| | **Modification** | The pending change state: **Added**, **Changed**, or **Removed**. Blank if the entity is unchanged since the last accepted revision. | | ||
| | **Revision** | The schema version of the entity's event payload. See [Revisions](#revisions). | | ||
| | **Topic** | The Kafka topic name for this entity, in the format `cdc.<app-name>.<ExposedName>.<revision>.{space}`, where `{space}` is replaced at runtime by the Event Broker space name. | | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
You can link to the actual runtime configuration here. |
||
|
|
||
| ### Adding an Entity {#add-entity} | ||
|
|
||
| 1. Click **+ Add** in the toolbar. | ||
| 2. Select a persistable entity from the domain model. | ||
| 3. Optionally edit the **Exposed name**. | ||
| 4. Expand the row to deselect any attributes or associations you do not want included in the event payload. | ||
|
|
||
| ### Attribute and Association Selection {#attributes} | ||
|
|
||
| Expand an entity row to see each attribute and association with a checkbox. Uncheck an item to exclude it from the event payload. The **Exposed name** column lets you rename individual attributes in the payload independently of their domain model names. | ||
|
|
||
| Associations appear as nested data within the parent entity's event payload. They do not produce separate Kafka topics and show no **Revision** or **Topic** values of their own. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
|
||
|
|
||
| ## Revisions {#revisions} | ||
|
|
||
| Each tracked entity has a **Revision** number that identifies the schema version of its event payload. Downstream consumers use the revision to detect and respond to schema changes. The revision is also embedded in the Kafka topic name, so each schema version has its own isolated topic. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
we only use the major version of the schema version in topic name. If the change is minor, then you don't get a new topic name. |
||
|
|
||
| Studio Pro manages revisions automatically. When you modify the tracked configuration of an entity, Studio Pro marks it as **Changed** and calculates the new revision based on whether the change is breaking or non-breaking: | ||
|
|
||
| * **Minor revision** (for example, `1.0` → `1.1`) — a non-breaking change such as adding a new attribute. Existing consumers can continue reading the topic without modification. | ||
|
Check failure on line 73 in content/en/docs/refguide/modeling/integration/change-data-capture/published-cdc-services.md
|
||
| * **Major revision** (for example, `1.0` → `2.0`) — a breaking change such as removing an attribute, renaming an entity's exposed name, or removing an entity from tracking. Consumers must be updated to use the new topic. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Here I assume we are talking about revision for entity. We do have revision for document but that is hidden. The explanation here seems to be leading toward the revision for document, especially the following description "renaming an entity's exposed name, or removing an entity from tracking." I am going to check in Studio Pro if this is true. It is possible that when you rename exposed name then you would get v1 again since the topic name is unique enough e.g.
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I checked the Studio Pro and we do increase major version if the exposed name get renamed. I think we can leave this description as-is. |
||
|
|
||
| {{< figure src="/attachments/refguide/modeling/integration/change-data-capture/published-cdc-service-changes.png" alt="Published CDC Service document showing entities with Changed and Removed modification states and updated revision numbers" >}} | ||
|
|
||
| ### Accepting Changes {#accepting-changes} | ||
|
|
||
| Pending modifications are not finalized until you click **Accept changes** in the toolbar. Until you do, Studio Pro shows a consistency error on the document. You must resolve this error by accepting the changes before you can deploy the app. | ||
|
|
||
| Accepting changes confirms the new revision numbers and clears the modification states, leaving the document in a clean state ready for deployment. | ||
|
|
||
| {{% alert color="warning" %}} | ||
| A major revision creates a new Kafka topic. Consumers subscribed to the previous topic version will no longer receive events after deployment. Ensure downstream systems are updated before deploying a major revision change. | ||
|
Contributor
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
How is this possible? I think the ordering is for provider side to deploy first, then the consumer side can get the updated topic name. The consumer are free to consume the old topic name but it won't be updated. |
||
| {{% /alert %}} | ||
|
|
||
| ## Runtime Behavior {#runtime} | ||
|
|
||
| * The CDC service runs in the system context — no user security applies. | ||
| * Events are published for every committed object change: create, update, and delete. | ||
| * Kafka topics are created automatically on deployment for each tracked entity. | ||
| * Events use [CloudEvents](https://cloudevents.io/) payload format, consistent with other Mendix Event Broker services. | ||
|
|
||
| ## Read More | ||
|
|
||
| * [Change Data Capture](/refguide/change-data-capture/) | ||
| * [Mendix Event Broker](/appstore/services/event-broker/) | ||
| * [Event Broker Bridges](/appstore/services/event-broker/#manage-mx-broker-bridge) | ||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Mention about snapshot too to complete the CRUD. In this case snapshot would be [R]ead.
It would be a good idea to mention Leader Selection and its configuration.