У меня есть вариант использования, когда я получаю данные по шести темам Kafka и материализую их в Ktables, применяю различные соединения и агрегации, а затем хранение их в базе данных. Теперь, как только он хранится в базе данных, я хочу немедленно удалить все связанные записи из государственных магазинов, которые использовались во время обработки, чтобы это помогло мне сохранить пространство дисков.
Подробнее здесь: https://stackoverflow.com/questions/797 ... processing
