A producer team tries to publish version 5 of the checkout_events schema

A medium Pipeline Design interview practice problem on DataDriven. Write and execute real pipeline design code with instant grading.

Domain

Pipeline Design

Difficulty

medium

Problem

A producer team tries to publish version 5 of the checkout_events schema. Version 5 renames amount to amount_cents, which is incompatible with both backward and forward read of the existing topic. Without a registry the rename would land on the topic, every consumer would either read NULL or fail, and the breakage would be discovered in production. The section's fix is to make the registry the gatekeeper: schemas register before publishing, the registry runs a compatibility check, and incompatible schemas are rejected at registration so they never enter the system. Spot the rejected schema by adding a schema registry node between the producer and the Kafka topic whose name states it runs a compatibility check, and add an annotation showing where the v5 schema is rejected.

Practice This Problem

Solve this Pipeline Design problem with real code execution. DataDriven runs your solution and grades it automatically.