Топология потока Kafka Для обновления присоединенного KTable из другого типа события - PullRequest
0 голосов
/ 15 апреля 2019

Пример, который я пытаюсь выяснить, следующий:

У нас есть три типа событий.

  1. School_Created - Событие, указывающее, что школа была создана.Переносит все метаданные для школы.
  2. Student_Created - событие, указывающее, что ученик создан.Получил ссылку на школу.
  3. Student_Updated - обновлены некоторые сведения об ученике.

С учетом трех типов событий нам необходимо создать материализованные представления агрегаций между школами.и студенты.

Теперь присоединиться и объединить события School_Created и Student_Created прямо сейчас.Но как мы можем обработать событие Student_Updated.

Я имею в виду, соединяя School_Created и Student_Created, мы можем создать KTable с хранилищем состояний с именем Student_School_Detail.Но когда у нас есть событие Student_Updated, нет способа обновить таблицу Student_School_Detail.Единственный способ, который я вижу, это присоединиться к Student_School_Detail с событием Student_Updated и создать еще один KTable.

Это единственный способ, которым мы могли бы сделать это, или у нас есть лучший способ?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...