Блог

Я пытаюсь использовать несколько тем кафки, в которых есть события, связанные с одними и теми же объектами. ключ сегментирования одинаков для объекта по разным темам, и мне нужно иметь возможность обрабатывать события одновременно. На данный момент я нашел несколько возможных решений, но мне нужен совет, каким путем идти :

1. используйте по одному актору на элемент : это позволяет обрабатывать параллелизм из-за полноты состояния приложения
2. Используйте один и тот же сегмент между темами кафки и потребителем Akka. Это верно при использовании одной темы, но остается ли сегментация в потоках akka одинаковой при использовании нескольких тем ? зная, что все темы имеют одинаковый номер раздела и один и тот же ключ для одного и того же объекта, есть ли способ «объединить» потоки в akka для одновременной обработки событий, относящихся к одному и тому же объекту ?

Спасибо за любую предоставленную помощь/понимание