Мы записываем историю действий пользователя и хотим агрегировать их, чтобы обновлялся счёт пользователя. Каким образом лучше организовать балансировку отправки событий в Kafka?