def wait_consumer(self):
    print('wait_consumer')
    consumer = KafkaConsumer(self.requestID, bootstrap_servers=[lowDefine.KAFKA_SERVER_URL], auto_offset_reset='earliest', enable_auto_commit=True, group_id=self.requestID, value_deserializer=(lambda x: loads(x.decode('utf-8'))), consumer_timeout_ms=(1000 * 10))
    print('w-1')
    res = None
    for message in consumer:
        print(('Topic: %s, Partition: %d, Offset: %d, Key: %s, Value: %s' % (message.topic, message.partition, message.offset, message.key, message.value)))
        res = message.value
        break
    consumer.close()
    return res
def wait_consumer(self):
    print('wait_consumer')
    consumer = KafkaConsumer(self.requestID, bootstrap_servers=[lowDefine.KAFKA_SERVER_URL], auto_offset_reset='earliest', enable_auto_commit=True, group_id=self.requestID, value_deserializer=(lambda x: loads(x.decode('utf-8'))), consumer_timeout_ms=(1000 * 10))
    print('w-1')
    res = None
    for message in consumer:
        print(('Topic: %s, Partition: %d, Offset: %d, Key: %s, Value: %s' % (message.topic, message.partition, message.offset, message.key, message.value)))
        res = message.value
        break
    consumer.close()
    return res