Thanks for reply. I have already imported kafka-clients-0.10.2.1.jar in the project class path.

Earlier it was giving plugin error while executing statement Trans trans=new Trans(metadata); but after importing above plugin it started giving error in next line below:-

trans.execute(null); // Error while executing this statement

Please see screenshots and ktr files i have attached Actually my Kafka consumer transformation takes another sub transformation :"Get record for stream" which writes json message to mongo in this transformation. it seems due to nested/sub trasnformation it is giving this error. but log is not very descriptive so i am unable to find out which further plugin is missed. Kindly refer attachments

It's the *Pentaho* kafka plugin that is missing in your environment. This is more than just the kafka jars. I don't know but I think you'll have to find a way to initialize pdi with it's plugins as well, is the kafka plugin an osgi one?

Have a look in the plugins/steps folder and read up on that side of things.