Pentaho

Hi All,

I created a Pentaho kafka consumer transformation (2.ktr) in pentaho kettle 8.1 to consume kafka json messages with "get records from stream" sub transformation (3.ktr)

This "get records from stream"  sub transformation parse messages with "input json" and save it in "mongo db output".

But when i am running below code to execute above transformation through eclipse i am getting exception. Please suggest so that i can run below trasnformation program successfully.

i have attached ktr files,  screenshots and code below please refer

================================= Java code=============================

public static void main(String[] args) {

String file="c:/pdi/2.ktr";

try {

          KettleEnvironment.init();

          TransMeta metadata=new TransMeta(file);

          Trans trans=new Trans(metadata);

          trans.execute(null); // GETTING EXCEPTION HERE

          trans.waitUntilFinished();

          if(trans.getErrors()>0){

               System.out.println("Error Executing Transformation");

          }

     } catch (KettleException e) {

          e.printStackTrace();

     }

============Exception============\

2018/08/26 15:07:49 - Kafka Consumer.0 - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Can't run transformation due to plugin missing

2018/08/26 15:07:49 - Kafka Consumer.0 - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Error initializing step [Kafka Consumer]

2018/08/26 15:07:49 - 2 - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Step [Kafka Consumer.0] failed to initialize!

org.pentaho.di.core.exception.KettleException:

We failed to initialize at least one step.  Execution can not begin!

at org.pentaho.di.trans.Trans.prepareExecution(Trans.java:1163)

at org.pentaho.di.trans.Trans.execute(Trans.java:627)

at RunningTransformations.runTransformationFromFileSystem(RunningTransformations.java:153)