Showing posts from 2015

Monitoring Apache Storm using JConsole

When you setup a storm cluster in a production environment it is important to monitor performance and resource usage of storm components to make sure that your cluster is working smoothly without issues.
This post will guide you to enable JMX and monitor storm components using JConsole. Mainly there are two nodes to monitor in a storm cluster Nimbus NodeSupervisor Node Configure Nimbus Node  Open storm.yaml file located at Nimbus_HOME>/conf/ directory and add below configurations.
Here I will be enabling JMX at port 9997. You can specify a preferred port here.Add the host name of nimbus nodenimbus.childopts: "-Xmx1024m -Djava.rmi.server.hostname=" Start storm nimbus using below command
./storm nimbus Configure Supervisor Node Open storm.yaml file …

Setting up Apache Storm Topology for CEP distributed mode deployment

This post will guide you through the storm part of the configuration for the wso2 Complex Event Processor(CEP) deployment in distributed mode. Please refer: for the CEP part of the configuration. 

Here I will be illustrating a basic storm setup, with three instances running as below diagram.

Their details are as below
Nimbus host - host - host - Zookeeper I will be referring the location of zookeeper folder  as <Zookeeper_HOME>.

1. Download  zookeeper  from here
2. Extract the file to instance
3. Go to <Zookeeper_HOME> directory and create a folder called 'data'.
4. Zookeeper needs a configuration file to start. You can create a file called zoo.conf inside <Zookeeper_HOME>/conf directory
tickTime=2000 dataDir=<Zookeeper_HOME>/zookeeper-3.3.6/data clientPort=2181
5. Open a terminal and go to &…