def METHOD_NAME(complete_conf):
    setup_configs(complete_conf)
    java_path = os.path.join(os.getcwd(), LOCAL, "bin")
    os.environ["PATH"] += os.pathsep + java_path
    os.environ["JMX_PORT"] = KAFKA_CONNECT_JMX_PORT
    os.environ["KAFKA_LOG4J_OPTS"] = "-Dlog4j.configuration=file:" + os.path.join(
        os.getcwd(), LOG4J_CFG_PATH
    )
    kafka_connect_heap_opts = os.environ.get(
        "DATABROKER_KAFKA_CONNECT_HEAP_OPTS", "-Xms512M -Xmx2G"
    )
    os.environ["KAFKA_HEAP_OPTS"] = kafka_connect_heap_opts
    env = dict(os.environ)
    kafka_connect_process = DataBrokerProcess(
        PROCESS_NAME,
        (KAFKA_CONNECT_START_PATH, KAFKA_CONNECT_CFG_PATH),
        env,
    )
    # Wait for kafka connect to initialize
    # and then issue a request for debezium connector
    time.sleep(INITIAL_WAIT)
    debezium_config = json.loads(debezium_generator.generate_config(complete_conf))
    def backoff_hdlr(details):
        logging.warning(
            "Databroker: Failed to receive successful response from connect. "
            "Retrying...(%d/%d)",
            details["tries"],
            MAX_RETRIES,
        )
    def giveup_hdlr():
        logging.error("Databroker: Kafka Connect wait retries exhaused")
        raise Exception("Databroker: Kafka Connect failed to start")
    @backoff.on_predicate(
        backoff.constant,
        interval=BACKOFF_TIME,
        max_tries=MAX_RETRIES,
        on_backoff=backoff_hdlr,
        on_giveup=giveup_hdlr,
    )
    @backoff.on_exception(
        backoff.constant,
        Exception,
        interval=BACKOFF_TIME,
        max_tries=MAX_RETRIES,
        on_backoff=backoff_hdlr,
        on_giveup=giveup_hdlr,
    )
    def start_debezium_connector():
        return requests.put(
            f"{CONNECT_URL}/{debezium_config['name']}/config",
            json=debezium_config["config"],
        )
    start_debezium_connector()
    return kafka_connect_process