案例四 流式處理（kafka）

意圖：從kafka消費數據共200條，進過一系列處理、聚合，輸出40條到數據庫 整個過程分爲父轉換SRT，子轉換SKafkaProcess ，SRT拉取kafka數據，SKafkaProcess 負責處理，大體呈：數據 -> SRT -> SKafkaProcess ->結果。 爲毛分兩個轉換，爲毛不是一個轉換？因爲【Kafka consumer】這個步驟配置界面需要輸入另一個轉換。我的理解是消費

>>阅读原文<<