JVMMetricsHandler implements KafkaHandler { @Override public String getTopic() { return config.getTopicNameOfMetrics(); } JVMMetricsHandler(ModuleManager moduleManager, KafkaFetcherConfig config); @Override void handle(final ConsumerRecord<String, Bytes> record); @Override String getTopic(); @Override String getConsumePartitions();  }
@Test public void testTopicName() { Assert.assertEquals(handler.getTopic(), TOPIC_NAME); }