if you change the ip list data in mongodb ,you can programitaclly write a queue msg to kafka (or redis ).in your bolt process part, you can read queue if msg exists, update your ip list var in your bolt instance property.
------------------ ???????? ------------------ ??????: "Ritesh Sinha"; ????????: 2015??8??6??(??????) ????5:11 ??????: "user"; ????: Updating Changes after the cluster is submitted I need to write a bolt which processes the messages on the basis of IP. Basically , i have a list of IP's stored in mongoDB.All the messages i get will contain IP's, So , i need to check if that particular IP is present in the list or not if it is present then i need to ignore the message else process it. The list of IP is dynamic .There can be addition or deletion of IPs after the topology has been deployed to storm. The problem is either I need to keep the IP is memory(but the changes can't be reflected once the list is updated) or read it every time from mongoDB, which makes the processing slow. Is there any way to implement it efficiently ? Is it possible to trigger any event if addition or deletion of IP has happened in mongoDB ?
