自定义步骤插件-案例

简要

意图：实现一个实时拉取数据处理kafka消费步骤
自定义步骤如下：

处理流程如下：

发到kafka的原始数据如下：

结果：

搭建好IDEA的Java开发环境。为了节省解决各种依赖关系的时间，而且有些依赖下载太慢，所以不用maven。再者Kettle工作目录里已经有完备的jar包。所以从工作目录data-integration\lib下，拷贝以下jar包到工程中，做好依赖配置