class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long getKafkaCommitTimer() {
    return get(TIMER_KAFKA_COMMIT);
  }

  public  KafkaSourceCounter(String name);

}