@Test(dataProvider = "getSupervisorMetrics")
public void testCollectSupervisorStats(Set<MetricsItem> items, boolean expected) {

  BasicMetricsCollector collector = new BasicMetricsCollector(config, topology, items);
  assertThat(collector.collectSupervisorStats).isEqualTo(expected);
}