Sorry for some mistakes in the description. The fact is some Bolts missed some notifications from Zookeeper when the node changed or the said notifications were not triggered at all. I do not know which case it is actually.
________________________________ [email protected] 发件人： 王 纯超<mailto:[email protected]> 发送时间： 2018-07-09 12:53 收件人： [email protected]<mailto:[email protected]> 主题： NodeCache Notification Failure 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.
