Если у вас есть события о разных сущностях, должны ли они go на одну и ту же тему c или на разные темы? Здесь я бы предпочел использовать Kafka в качестве системы обмена сообщениями между издателями и потребителями. Эти разные источники имеют разные модели с несколькими общими атрибутами, а другие определяют c для каждой модели. Необработанные данные / события для этих моделей будут обрабатываться отдельно.
Q1. Давайте рассмотрим две разные модели, выступающие в роли издателя или источника потока. В распределенной системе они должны отправлять события в одну топику c или соответствующие темы?
Q2. Что если в событии участвуют несколько объектов? Например, не только две модели, как упомянуто выше, но и тысячи, от которых пострадает задержка Kafka, например модель, связанная с покупкой, продукт и клиент, а также перевод с одного аккаунта на другой, включают как минимум эти два аккаунта.
Q3. Для обоих случаев какая схема предпочтительнее AVRO (развивается, но для одной модели на топи c) или JSON схема?