简要

意图:实现一个实时拉取数据处理kafka消费步骤
自定义步骤如下:
自定义步骤插件-案例
处理流程如下:
自定义步骤插件-案例
发到kafka的原始数据如下:
自定义步骤插件-案例
结果:
自定义步骤插件-案例自定义步骤插件-案例
搭建好IDEA的Java开发环境。为了节省解决各种依赖关系的时间,而且有些依赖下载太慢,所以不用maven。再者Kettle工作目录里已经有完备的jar包。所以从工作目录data-integration\lib下,拷贝以下jar包到工程中,做好依赖配置
自定义步骤插件-案例

相关文章: