BaseConsumer.py 文件源码

def exit_gracefully(self, signum, frame):
        '''exit the consumer gracefully'''
        if not self.message_processing:
            self.logger.info("Fast shutdown available ... exiting (signum %d)" \
                             % (signum))
            self.logger.info("Print stack trace. Don't panic!")
            self.logger.info("-----------------------------------------------")
            for chunk in traceback.format_stack(frame):
                for line in chunk.split("\n"):
                    self.logger.info(line)
            self.logger.info("-----------------------------------------------")
            for part in self.partitions:
                self.partitions[part].writer.close()
            self.consumer.commit()
            sys.exit(0)

        self.logger.info("Graceful shutdown of consumer " +
                         str(self.consumer_id) + " started....")
        self.shutting_down = True