из того что я нашел и придумал
1. Использовать определенный хеш, чтобы например все сообщения, например с id продукта попадали в один partition, самое простое это id mod n где n это количество партиций.
2. Использовать кэш по типу редиса чтобы там перед тем как отдавать отсортировать сообщения в правильном порядке, например по полю timestamp
3. Просто использовать одну партицию и все
Подскажите может есть другие варианты решение данной проблемы?
В 1м варианте вы просто можете писать с ключем id
обычно используют id как key, тогда все объекты с одним и тем же id пойдут в одну и ту же partition
3. 1 уже как бэ включает 3, но не надо мудрить со своими хэшами
Обсуждают сегодня