def loop(self):

    while True:
      messages = self.consume()

      if messages and isinstance(messages, list) and len(messages) > 0:
        for message in messages:
          yield message

      time.sleep(self.polling)

  # REQUEST TYPE ID + TOPIC LENGTH + TOPIC + PARTITION + OFFSET + MAX SIZE
Ensures that MySQL connections checked out of the pool are alive.
dataset/ETHPy150Open harelba/tail2kafka/kafka/consumer.py/Consumer.loop--crossover with--dataset/ETHPy150Open openstack/taskflow/taskflow/persistence/backends/impl_sqlalchemy.py/_ping_listener