Kafka Streams Rocks Разметка БД - PullRequest
       6

Kafka Streams Rocks Разметка БД

0 голосов
/ 18 января 2019

У меня есть требование, когда я хочу отправить данные с истекшим сроком в долгосрочную базу данных. В настоящее время мы используем KeyValueStore и самостоятельно управляем старыми данными. Я знаю, что есть WindowStores, которые будут периодически удалять старые данные.

Есть ли способ использовать KeyValueStore, но создать базу данных многораздельных пород, и мы можем управлять тем, в какой раздел записывать и удалять записи. Или воспользуйтесь оконным хранилищем и перехватите процесс, удаляющий раздел, чтобы мы могли отправить эти данные куда.

...