Hello, Can someone help on how can I achieve this using DataStream API, I have 2 topics, topic1- will have

surface visited

events with

visitId

field. topic2- will have

surface visits linked

events which has

sourceVisitId

and

destinationVisitId

which will basically link 2 surface visiteds event say SV1 and SV2. requirement is to stream events from both the topics and copy the attributes of SV1 to SV2 using surface visits linked event coming from topic2. we can think of window as 30 mins