Как Kafka обеспечивает версионирование сообщений?

Kafka не обеспечивает версионирование сообщений напрямую, но предоставляет механизмы для его реализации.

Основные подходы:

• Поле версии в схеме — включение номера версии в структуру сообщения
• Schema Registry — управление версиями схем с проверкой совместимости через Confluent Schema Registry
• Заголовки сообщений — передача метаинформации о версии через Kafka Headers

На собеседовании: на практике Schema Registry — стандартный способ управления версиями. Без неё эволюция схемы превращается в координацию между командами, что ненадёжно.