Hello
I have a question regarding the combination of Kafka, Storm and Redis.
I have created a Kafka producer, which produces messages like this:
1000 100 on
2000 150 off
The first two values are IDs, the third value is the information about the state of a device “on” or “off”.
I have also created a Kafka spout in Storm and I already receive these messages in my Storm topology.
Now I would like to store the “on” messages in Redis and to delete the “off” messages from Redis. There should always be an actual list of all “on” devices in Redis, which I can use afterwards for my analysis.
Unfortunately I have no idea how to realize this. Do I have to split the messages or can I store/delete them as they are? How could this be realized?
Thank you very much in advance.
Regards,
Daniela
