Function write_consumer_properties

system_test/utils/kafka_system_test_utils.py:2500–2507

(consumerProperties)

    return leaderDict

def write_consumer_properties(consumerProperties):
    import tempfile
    props_file_path = tempfile.gettempdir() + "/consumer.properties"
    consumer_props_file=open(props_file_path,"w")
    for key,value in consumerProperties.iteritems():
        consumer_props_file.write(key+"="+value+"\n")
    consumer_props_file.close()
    return props_file_path