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
