Usecase: Module 1: We need to read data from an Kafka topic. This topic will contain different types of data, and then we need to aggregate the value against each type and store it in a Redis cache.

Module 2: Now if the aggregate value for any type breaches a threshold we need to perform certain actions.

I was thinking to create 'n' number of redis caches in active-passive mode for each unique type which we process from kafka topic. Now the Module 2 will poll or stream from each active instance of redis cache and if the threshold is breached then it will make passive as Active. This will make sure new messages from kafka will be processed in the cache.

Questions:

1) how is the process.

2) How can we use Active/passive redis cache.