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