def consume(self):

    self.send_consume_request()

    return self.parse_message_set_from(self.read_data_response())
Test whether this command can be found in the bash shell, by executing
dataset/ETHPy150Open harelba/tail2kafka/kafka/consumer.py/Consumer.consume--crossover with--dataset/ETHPy150Open jonathanslenders/python-deployer/deployer/host_container.py/HostContainer.has_command