II.
Workflow JSON
Structured · liveworkflow:cdc-pipeline-validation
CDC Pipeline Validation json
Inspect the normalized record payload exactly as the atlas UI reads it.
{
"id": "workflow:cdc-pipeline-validation",
"_kind": "Workflow",
"_file": "workflows/workflows/workflows-data-eng-deep.yaml",
"_cluster": "workflows",
"attributes": {
"displayName": "CDC Pipeline Validation",
"workflowKind": "data",
"triggerType": "event-driven",
"typicalCadence": "per-change",
"complexity": "cross-team",
"description": "Validates change data capture pipelines after source schema changes or\nconnector upgrades — verifying Debezium/CDC connector configuration\ncorrectness, testing schema evolution compatibility, measuring consumer lag\nagainst SLA thresholds, checking exactly-once delivery guarantees,\nvalidating dead-letter queue handling, and confirming end-to-end data\nconsistency between source and sink. Excludes CDC architecture design.\n"
},
"outgoingEdges": [
{
"from": "workflow:cdc-pipeline-validation",
"to": "role:data-scientist",
"kind": "involves_role",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "role:database-administrator",
"kind": "involves_role",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "role:platform-engineer",
"kind": "involves_role",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "skill-area:kafka-stream-processing",
"kind": "requires_skill_area",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "skill-area:python-data-pipelines",
"kind": "requires_skill_area",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "domain:data-science",
"kind": "applies_to_domain",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "domain:databases",
"kind": "applies_to_domain",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "responsibility:data-quality-monitoring",
"kind": "triggers_responsibility",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "responsibility:respond-incidents",
"kind": "triggers_responsibility",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "org-unit:data-platform-team",
"kind": "performed_by_org_unit",
"attributes": {}
},
{
"from": "workflow:cdc-pipeline-validation",
"to": "org-unit:database-team",
"kind": "performed_by_org_unit",
"attributes": {}
}
],
"incomingEdges": []
}