Как сделать последовательную обработку событий Kafka по указанному параметру сообщения при наличии нескольких партиций?

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

Существует ли способ исключить параллельную обработку сообщений имеющих одно и тоже значение параметра "group_id" при наличии нескольких партиций и потребителей?


Ответы (0 шт):