如何检查 WSO2 CEP 是否正确配置了用于分布式处理的 Apache 风暴

How to check WSO2 CEP is correctly configured with Apache storm for distributed processing

我正在使用最新的 WSO2 CEP (v4.1.0) 和 apache storm 0.9.6 以分布式方式进行 WSO2 CEP 集群(distributed mode deployment). I have followed the guidelines WSO2 为 CEP 集群提供。

遵循这些准则后,CEP 可以正常工作。现在我想确保 CEP 正确集群或 not.Is 有任何机制来检查它是否配置正确。

您应该能够看到类似如下的日志。可以在日志中看到其他成员的IP和集群端口。

INFO - MemberUtils Added member: Host:192.168.1.100, Remote Host:null, Port: 4200, HTTP:-1, HTTPS:-1, Domain: null, Sub-domain:null, Active:true
INFO - HazelcastClusteringAgent Hazelcast initialized in 1283ms
INFO - HazelcastClusteringAgent Local member: [03fa03f7-176b-48d5-9173-48866d7dd641] - Host:192.168.1.100, Remote Host:null, Port: 4100, HTTP:8280, HTTPS:8243, Domain: wso2con.domain, Sub-domain:mgt, Active:true
INFO - HazelcastClusteringAgent Elected this member [03fa03f7-176b-48d5-9173-48866d7dd641] as the Coordinator node

[2015-09-14 11:31:44,162]  INFO - WKABasedMembershipScheme Member joined [a0f1c3cd-adaf-4fdf-ac9f-d6c6f3508022]: /192.168.1.100:4300
[2015-09-14 11:31:46,230]  INFO - MemberUtils Added member: Host:192.168.1.100, Remote Host:null, Port: 4300, HTTP:8282, HTTPS:8245, Domain: wso2con.domain, Sub-domain:worker, Active:true

我尝试了 WSO2 提供的 sample 之一。然后 Storm UI 将显示根据给定的 Siddhi 查询创建的喷口和螺栓。使用它我们可以决定 CEP 是否正确聚类。

Apche 风暴 UI 以下列方式显示螺栓和喷口。