class KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean {

  public long getKafkaEventGetTimer() {
    return get(TIMER_KAFKA_EVENT_GET);
  }

  public  KafkaSourceCounter(String name);

}