### Question:
KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean { public long getKafkaEmptyCount() { return get(COUNTER_KAFKA_EMPTY); } KafkaSourceCounter(String name); long addToKafkaEventGetTimer(long delta); long addToKafkaCommitTimer(long delta); long incrementKafkaEmptyCount(); long getKafkaCommitTimer(); long getKafkaEventGetTimer(); long getKafkaEmptyCount();  }### Answer:
@Test public void testGetKafkaEmptyCount() throws Exception { Assert.assertEquals(0, counter.getKafkaEmptyCount()); }