Fetching information with Nimbus thrift

In this section, we will be creating a Java project that will contain classes that will perform the following operations using the Nimbus thrift client:

  • Collect the Nimbus configuration
  • Collect the supervisor statistics
  • Collect the topology statistics
  • Collect the spout statistics for a given topology
  • Collect the bolt statistics for a given topology
  • Kill the given topology

The following are the steps to fetch the cluster details using the Nimbus thrift client:

  1. Create a Maven project by using com.stormadvance as groupId and stormmonitoring as artifactId.
  2. Add the following dependencies to the pom.xml file:
<dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>1.0.2</version> ...

Get Mastering Apache Storm now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.