Hi all, I want to have Storm respond to outside notification and update Bolt state accordingly. Currently, I am using Zookeeper to achieve this by making the Bolt watch a specific Zookeeper node (through NodeCache). There are a lot of Bolts, of high parallelism, watching the same node. But it is observed that different Bolts got notified different times. It is expected that one and only one notification should be triggered for one node change.
Did anyone encounter this ever? Is there any better solution for this scenario? By the way, KafkaSpout does not adopt the above method to monitor Kafka cluster change. What is the consideration? Any help is appreciated.
