class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long getKafkaEmptyCount() {
    return get(COUNTER_KAFKA_EMPTY);
  }

  public  KafkaSourceCounter(String name);

}