еще один топик2, в котором идет подмножество событий топика1.
Задача из потока событий 1 вычесть(убрать) события 2 и положить разницу в третий топик.
Как такое можно сделать? Может быть как-то используя Kafka Streams?
Подскажите, может быть кто-то решал такую или подобную задачу, куда копать?
kafka streams, да
А оно как-то где-то умеет состояние хранить? события могут не совсем синхронно приходить, нужно дождаться события в топике2, которое нужно вычитать. Или там вся эта магия под капотом уже есть?
Клади в Кассандру события топика2 с ттл и фильтруй топик1
Это требуется делать в реалтайме или оффлайн? Другими словами, есть ли ситуация когда в одном из топиков сообщение появится позже проведения проверки?
у меня есть предчувствие, что вам поможет camel и eip
Да, сообщения в топиках не синхронизированы
Обсуждают сегодня