class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long addToKafkaCommitTimer(long delta) {
    return addAndGet(TIMER_KAFKA_COMMIT,delta);
  }

  public  KafkaSourceCounter(String name);

}