Crate rlink_sink_conf

rlink-sink-conf

A library to upgrade rlink task smoothly.

Example

use rlink_sink_conf::sink_config::{init_sink_config, get_sink_topic};
use std::collections::HashMap;

let sin_conf_url = "testUrl";
let application_name = "tlb_base_qa";
let timestamp = 123 as u64;

init_sink_config(sin_conf_url.to_string(), application_name.to_string());

let mut expression_param = HashMap::new();
expression_param.insert("timestamp".to_string(), timestamp.to_string());
let sink_topic = get_sink_topic(expression_param);

Modules

sink_config