Thanks Joe for the reply. I had tried this - adding this in kafka_2.10-0.8.2.1.jar . Got the following error
Couldn't find any input plugin named 'kafka'. Are you sure this is correct? Trying to load the kafka input plugin resulted in this error: cannot load Java class kafka.consumer.ConsumerIterator
I verified the missing file the above error mentions and related files are there in the repackaged jars.
My logstash version is 2.1.1. and java env is 1.8.0_31. Can the java version be an issue in case this and other original jar files in the distribution were compiled and archived in java 1.7.x environment? Any other reason ?