Hi Rishikesh, Is it possible to create another kafka stream based on Curr_stream1 & Curr_stream2? In this case, you will be able to stream (Curr_stream1.f0 - Curr_stream2.f0) into a new Ignite cache and use continuous query.
In any way, it would be great if you can share your solution with the community. Thanks. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/