public synchronized void reset(){
  labels.clear();
  labels.put(SensisionConstants.SENSISION_LABEL_TOPIC,this.topic);
  labels.put(SensisionConstants.SENSISION_LABEL_GROUPID,this.groupid);
  for (int i=0; i < this.counters.length; i++) {
    if (null == this.counters[i]) {
      continue;
    }
    labels.put(SensisionConstants.SENSISION_LABEL_PARTITION,Integer.toString(i));
    Sensision.clear(SensisionConstants.SENSISION_CLASS_WARP_KAFKA_CONSUMER_OFFSET,labels);
    this.counters[i]=null;
  }
}

public synchronized void reset ( ) { labels . clear ( ) ; labels . put ( SensisionConstants . SENSISION_LABEL_TOPIC , this . topic ) ; labels . put ( SensisionConstants . SENSISION_LABEL_GROUPID , this . groupid ) ; for ( int i = 0 ; i < this . counters . length ; i ++ ) { if ( null == this . counters [ i ] ) { continue ; } labels . put ( SensisionConstants . SENSISION_LABEL_PARTITION , Integer . toString ( i ) ) ; Sensision . clear ( SensisionConstants . SENSISION_CLASS_WARP_KAFKA_CONSUMER_OFFSET , labels ) ; this . counters [ i ] = null ; } }
remove per partition counters and associated sensision metrics
