自定義步驟插件-案例

簡要 意圖：實現一個實時拉取數據處理kafka消費步驟 自定義步驟如下： 處理流程如下： 發到kafka的原始數據如下： 結果： 搭建好IDEA的Java開發環境。爲了節省解決各種依賴關係的時間，而且有些依賴下載太慢，所以不用maven。再者Kettle工作目錄裏已經有完備的jar包。所以從工作目錄data-integration\lib下，拷貝以下jar包到工程中，做好依賴配置

>>阅读原文<<