1. 程式人生 > >Kettle安裝Kafka Consumer外掛

Kettle安裝Kafka Consumer外掛

下載軟體https://github.com/RuckusWirelessIL/pentaho-kafka-consumer/releases/tag/v1.5

cd /opt/kettle/data-integration/plugins

mkdir steps

解壓pentaho-kafka-consumer-v1.5.zip到steps目錄

更新lib目錄下的jar包與安裝的Kafka 2.11-0.10.0.1保持一致

同時修改/opt/kettle/data-integration/plugins/steps/pentaho-kafka-consumer/plugin.xml

重啟PDI 6.1,Input裡即可看到Apache Kafka Consumer

我把GoldenGate的資料以csv格式輸出到Kafka,在PDI中配置如下,資料然後輸出到文字檔案測試成功。