def METHOD_NAME(self, database_config):
    if not self.is_producer_app:
        return
    logging.info("Databroker: Initializing components")
    try:
        complete_conf = self.__setup_configs(database_config)
        if should_run_kafka_connect():
            self.kafka_connect = connect.METHOD_NAME(complete_conf)
        self.kafka_streams = streams.METHOD_NAME(complete_conf)
        logging.info("Databroker: Initialization complete")
    except Exception as ex:
        logging.error("Databroker: Initialization failed due to %s", ex)
        raise Exception("Databroker initailization failed") from ex
    if not self.restart_if_any_component_not_healthy():
        logging.error(
            "Databroker: component restart retries exhaused. Stopping the app"
        )
        sys.exit(0)