def consume(self):

    self.send_consume_request()

    return self.parse_message_set_from(self.read_data_response())
Consume data from the topic queue.
dataset/ETHPy150Open harelba/tail2kafka/kafka/consumer.py/Consumer.consume