Микросервисы и Kafka: объединять или не объединять

На мой взгляд, использование темы Kafka для нескольких сервисов или приложений является правильным подходом, если ваши сервисы не полагаются на нее повторно. Это означает, что служба должна один раз прочитать очередь, преобразовать данные во все, что ей требуется, и при необходимости сохранить их сама. Таким образом, тема становится не постоянным хранилищем данных, а скорее независимым способом ввода данных (как если бы вы вызывали службу напрямую с этими raw данными, но в более независимой манере, позволяя службе читать тему. всякий раз, когда будете готовы к этому с любой необходимой частотой). Это увеличивает устойчивость вашей системы в целом.

И есть связь, то есть raw данные. Но с моей точки зрения, для нескольких сервисов совершенно нормально понимать один и тот же формат данных (в теме) - если его формат в основном стабильный. Предполагается, что это raw данные, которые каждая служба должна преобразовать в форму, полезную для себя. Вам просто нужно убедиться, что формат данных raw правильно версируется, когда требуются изменения. А чтобы сервисы продолжали работать, вам, возможно, придется доставлять несколько версий одновременно, пока все сервисы не будут поддерживать последнюю версию. Этот тип архитектурного стиля используется во многих крупных системах и работает до тех пор, пока у вас нет сценария, в котором вам нужно требовать, чтобы формат данных raw очень часто изменялся таким образом, чтобы он несовместим с вашими проектами сервисов. (Если бы это было так, вам, вероятно, понадобится еще один уровень стабильной метамодели ниже, который может описывать динамические необработанные данные.)