В сценарии, когда несколько типов событий в одном домене создаются в одной теме, и потребителем потребляется только подмножество типов событий, мне нужен хороший способ прочитать тип события, прежде чем предпринимать какие-либо действия.Я вижу 2 варианта:
- Поместить тип события (пример "ORDER_PUBLISHED") в само тело сообщения (полезную нагрузку), которое будет похоже на независимый от брокера подход и имеет другие преимущества.Но может потребовать разбора каждого сообщения просто для того, чтобы узнать тип события.
- Использовать заголовки сообщений Kafka, которые позволят получать сообщения без дополнительного анализа полезной нагрузки.
Контекст является источником событий,Маленькие команды, маленькие полезные нагрузки.Там нет огромных тел для разбора.Golang.Все сообщения являются протобуфами.gRPC.
Каков типичный рабочий процесс в таком сценарии.
Я пытался зайти в Google по этой теме, но не нашел много примеров использования заголовков и хороших практик.Было бы здорово узнать, когда и как использовать заголовки сообщений Kafka, а когда нет.