public void stop(){
  isAlive.set(false);
  for (  KafkaConsumer<byte[],byte[]> c : consumers.values()) {
    c.wakeup();
  }
  kafkaConsumerExecutor.shutdownNow();
  holdingBuffer.clear();
  IOUtils.closeQuietly(this);
}

public void stop ( ) { isAlive . set ( false ) ; for ( KafkaConsumer < byte [ ] , byte [ ] > c : consumers . values ( ) ) { c . wakeup ( ) ; } kafkaConsumerExecutor . shutdownNow ( ) ; holdingBuffer . clear ( ) ; IOUtils . closeQuietly ( this ) ; }
the method is called in the deactivate method of the operator
