6 lines
269 B
Markdown
6 lines
269 B
Markdown
# log-stream-doublewrite
|
||
|
||
基于查询网关的动态日志预处理程序，接收原始日志根据对应schema定义进行数据清洗
|
||
同时将文件及文件元数据以约定格式写入对应Topic内供文件加载程序使用
|
||
并将结果回写到Kafka。
|