Hi,

A traditional kafka streams application (App1)  reading data from a kafka 
topic, doing aggregations resulting in some local state. The output of this 
application is consumed by a different application(App2) for doing a different 
task. Under some conditions, there is an external trigger (async event) which 
needs to trigger requests for all the keys in the local store to App2. To 
achieve this, we can read the local stores from all the replicas and send the 
request to App2.

This async event happens less frequently compared to the normal case that leads 
to the state creation in the first place. Are there any caveats doing it this 
way ? If not, any other suggestions ?

Thanks
Mohan

Reply via email to