为了保证实施数据的低延迟,对 Flink 任务进行了分析,主要分为 3 个环节,kafka-source 负责读取数据,data-transform 负责做数据转换,sr-sink 负责把数据写入到 StarRocks