как сравнить текущее событие со старым событием в потоках кафки - PullRequest
Новая
       11

как сравнить текущее событие со старым событием в потоках кафки

0 голосов
/ 20 июня 2019

У меня есть последовательность событий в теме T1 с key в качестве идентификатора сотрудника, value в качестве объекта сотрудника.

например: 

Key: Value (JSON)
     1000: bob,24,department1,etc
     1002: sam,35,department2,etc
     1003: anna,26,department1,etc
     1000: bob,34,department2,etc`

Используя потоки Кафки, мне нужно сравнить со старым значением, которое обрабатывается, и определить, является ли его CREATE, UPDATE и должно ли генерировать события для темы T2 скажем

например: 

Key: Value (JSON)
     1000: CREATE,bob,24,department1,etc
     1002: CREATE,sam,35,department2,etc
     1003: CREATE,anna,26,department1,etc
     1000: UPDATE,bob,34,department2,etc`

Как мне добиться этой функциональности? я могу использовать операцию уменьшения? Если да, то как?

...