code: def stop(self):
          '''
          Shutdown kafka consumer.
          '''
          log.info('Stopping te kafka listener class')
          self.consumer.unsubscribe()
          self.consumer.close(f stop(self):
          '''
          Shutdown kafka consumer.
          '''
          log.info('Stopping te kafka listener class')
          self.consumer.unsubscribe()
          self.consumer.close()
docs: Shutdown kafka consumer.