Как сделать последовательную обработку событий Kafka по указанному параметру сообщения при наличии нескольких партиций?
- Есть некий топик для которого настроено больше одной партиции
- Несколько инстансов приложения подписанных на данный топик (происходит параллельная обработка событий)
- Сообщение публикуемое в топике имеет следующую структуру:
{ "group_id": 1, // другие данные }
Существует ли способ исключить параллельную обработку сообщений имеющих одно и тоже значение параметра "group_id" при наличии нескольких партиций и потребителей?