@Test(dataProvider = "getStormBenchmark")
public void getMetricsCollectorShouldReturnProperCollector(
        StormBenchmark benchmark, Class collectorClass) {

  IMetricsCollector collector = benchmark.getMetricsCollector(config, topology);
  assertThat(collector)
          .isNotNull()
          .isInstanceOf(collectorClass);
}