def start_consuming_signalling_topic(signalling_topic_data):
    signalling_topic_data = json.loads(signalling_topic_data)
    logger.info('Starting %s topic', signalling_topic_data['topic'])
    logger.info('Sending POST request to %s', url_subscribe)
    r = requests.post(url_subscribe, json=signalling_topic_data)
    logger.info('Response: Code %s', r)
    global signalling_start
    signalling_start = True
    thread = threading.Thread(target=kafka_consumer_signalling_topic_handler, args=[signalling_topic_data])
    thread.start()
def start_consuming_signalling_topic(signalling_topic_data):
    signalling_topic_data = json.loads(signalling_topic_data)
    logger.info('Starting %s topic', signalling_topic_data['topic'])
    logger.info('Sending POST request to %s', url_subscribe)
    r = requests.post(url_subscribe, json=signalling_topic_data)
    logger.info('Response: Code %s', r)
    global signalling_start
    signalling_start = True
    thread = threading.Thread(target=kafka_consumer_signalling_topic_handler, args=[signalling_topic_data])
    thread.start()