Мне нужно создавать ежедневные и еженедельные дайджесты электронных писем для всех событий, захваченных для пользователя.
Я использую Kafka для записи каждого события в Kafka.Здесь я использую ключ как USERID.Итак, все сообщения отправляются на один и тот же идентификатор раздела.
. Давайте рассмотрим следующий случай: 1. Пользователь вошел в систему - одно событие 2. Пользователь создал заявку в службу поддержки - одно событие 3. Пользователь обновил изображение профиля- Одно событие
Теперь, в конце дня, если я хочу создать дайджест со всеми событиями для пользователя, как мне сгруппировать сообщения по идентификатору пользователя в Kafka и создать дайджест.Если мы храним одни и те же события для 1000 пользователей, непросто прочитать каждое сообщение в Кафке и сгруппировать его как-то программно.Есть ли эффективное решение для такой проблемы?Используя Kafka Streams API, KTable поможет в этом контексте?Пожалуйста, совет.