Идея заключалась бы в реализации KeySelector
, который отображает свои входные объекты на определенный ключ разделения,
но этот ключ может меняться со временем.
Правила отображения могут быть сохранены, скажем, в базе данных,
KeySelector
будет обновлять их периодически или по запросу.
Я не уверен, что это вызовет проблемы с состоянием Флинка или механизмом разделения потока.
Например, если вход Foo
был первоначально сопоставлен с ключом раздела 0,
но позже изменения в ключе раздела 1,
и клавиша 0 больше не используется,
будет мигать просто «забыть» клавишу 0 в какой-то момент?
Пример малого котлина.