简介
Kafka consumer 步骤,用于连接和消费 Apache Kafka 中的数据,它可以作为数据管道的一部分,将 Kafka 中的数据提取到 Kettle 中进行进一步处理、转换和加载,或者将其直接传输到目标系统中。
使用
场景
我需要订阅一个Kafka的数据,让Kettle 进行下一步的数据清洗。
1、将Kafka consumer 对象拖出来到面板
2、配置Kafka consumer
需要配置的信息
transformation直接new就行
在配置返回的字段
这样子就可以去消费kafka的消息了
3、启动转换
这样子就是成功了
我们可以在previewdata看到返回的数据