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

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