A Debezium CDC pipeline streams the payments database to a downstream Iceberg lakehouse and a regula
A medium Pipeline Design mock interview question on DataDriven. Practice with AI-powered feedback, real code execution, and a hire/no-hire decision.
- Domain
- Pipeline Design
- Difficulty
- medium
Interview Prompt
A Debezium CDC pipeline streams the payments database to a downstream Iceberg lakehouse and a regulatory reporting system. A DBA runs ALTER TABLE on payments.transactions in production: add merchant_country (additive), drop legacy_clearing_code (destructive). Both schema-change events are already in the change stream. The section names three enforcement policies: allow-additive (additive changes flow through, destructive changes blocked), block-breaking (any non-additive change halts the stream and pages on-call), and quarantine (destructive changes route to a quarantine topic for human decision). Set the CDC schema policy by adding a policy enforcement transform between Debezium and the downstream consumers whose name states which of the three policies it applies, and add a quarantine destination for blocked changes.
How This Interview Works
- Read the vague prompt (just like a real interview)
- Ask clarifying questions to the AI interviewer
- Write your pipeline design solution with real code execution
- Get instant feedback and a hire/no-hire decision