class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long addToKafkaEventGetTimer(long delta) {
    return addAndGet(TIMER_KAFKA_EVENT_GET,delta);
  }

  public  KafkaSourceCounter(String name);

}