案例四 流式处理(kafka)

意图:从kafka消费数据共200条,进过一系列处理、聚合,输出40条到数据库 整个过程分为父转换SRT,子转换SKafkaProcess ,SRT拉取kafka数据,SKafkaProcess 负责处理,大体呈:数据 -> SRT -> SKafkaProcess ->结果。 为毛分两个转换,为毛不是一个转换?因为【Kafka consumer】这个步骤配置界面需要输入另一个转换。我的理解是消费
相关文章
相关标签/搜索