У нас есть Поток, который непрерывно читает потоковые сообщения из раздела Kafka и записывает их в таблицу MySQL subscribers, которая может включать операции вставки и обновления.
Теперь мы намереваемся сохранить другой поток для чтения сообщенийиз той же темы кафки и поддерживать совокупную сумму подписчиков.
Новая структура таблицы:
IDcount(subscribers)
структура таблицы подписчиков:
AccountIDSubscriberID
AccountID и SubscriberID - уникальная комбинация в таблице подписчиков, так какну.
Каковы возможные способы поддержки агрегатов в таких случаях?
Мне, конечно, нужно будет принять во внимание потоковые сообщения и уже существующие данные в subscriptions таблице