class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long incrementKafkaEmptyCount() {
    return increment(COUNTER_KAFKA_EMPTY);
  }

  public  KafkaSourceCounter(String name);

}