Выполнение сеанса в потоках Kafka из темы, которая должна позволять удаление определенного события (например, уплотнение).
События в теме событий, pageviews, должны быть сгенерированы с тем же ключом, чтобыбыть в состоянии выполнить сессию по этому.Но затем, если я хочу установить тематическую политику compact, чтобы иметь возможность удалять конкретные данные по требованию, если это требуется (подумайте о соответствии GDPR), сжатие может произойти в любое время, удаляя большую часть данных, которые собираютсябыть оконным
Как это можно надежно решить?