def wait_for_log_contains(self, text, level='info'):
        timeout = 1
        max_tries = 5
        while max_tries is not 0:
            if any(text in s for s in self.consumer_log_messages[level]):
                return True

            import time
            time.sleep(timeout)
            max_tries -= 1

        self.fail("Log message was not found %s" % text)