advanced

Kafka schema registry

Используйте schema registry и compatibility modes, чтобы evolve event contracts без break independently deployed producers and consumers.

Schema Registry хранит Avro, Protobuf или JSON schemas с version history и compatibility modes (BACKWARD, FORWARD, FULL). Producers регистрируют schemas; consumers deserialize с embedded schema IDs. Обеспечивает contract evolution между independently deployed services.

Компромисс: жёсткость предотвращает breaking changes, но требует discipline и CI checks; operational dependency от availability registry.

На интервью: optional field при BACKWARD compatibility; fail CI на incompatible change.

Типовые ошибки: обход registry с raw JSON; incompatible enum changes; нет subject naming strategy per topic.

Чеклист:

  • Registry в produce и consume paths.
  • Compatibility mode per subject осознанно.
  • Compatibility checks в producer CI.
  • HA registry и caching на clients.