采集kettle执行过程中，作业和转换中的SQL语句，发送到kafka中。
mvn clean package -DskipTests
打包后会在plugin目录生成对应zip包。使用插件时，上传插件包到kettle的plugin目录下进行解压。
收集转换时的SQL任务执行语句，传输到Kafka 所以需要kafka配置。在kettle 目录下放入 kafka.properties进行配置 kafka.properties
bootstrap.servers=localhost:9092
topic=TOPIC_METADATA_LINEAGE
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer文件结构
data-integration
|── kafka.properties
|── plugins/kettle-lineage-collector-plugin
├── kettle-lineage-collector-core-9.2.0.0-66.jar
├── lib
│ ├── jackson-databind-2.9.1.jar
│ └── kafka-clients-1.1.1.jar
└── version.xml备注本插件在kettle版本>=8已测试通过
进入kettle工程目录，打开spoon.sh 放开注释
OPT="$OPT -Xdebug -Xnoagent -Djava.compiler=NONE -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005"- spoon.sh 入口
org.pentaho.di.ui.spoon.Spoon - Kitchen 入口
org.pentaho.di.kitchen.Kitchen
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent