data-galaxy

kafka(local)

sink1.读取，存入

数据流向

source1.transform(脱敏)2. 失败重试

kafka(centre)

数据格式：{ \"c_url\": \"\

推入数据

opensearch