# Where to drop jar containing custome plugin or encoder like custom Kafka message decoder

**URL:** <https://discuss.elastic.co/t/where-to-drop-jar-containing-custome-plugin-or-encoder-like-custom-kafka-message-decoder/39190>\
**Category:** Logstash\
**Created:** [January 14, 2016, 5:39am UTC](https://discuss.elastic.co/t/where-to-drop-jar-containing-custome-plugin-or-encoder-like-custom-kafka-message-decoder/39190 "2016-01-14T05:39:59Z")\
**Posts on this page:** 1\
**Showing post:** 5

<div class="post-metadata">

**Author:** ![anandnsingh](https://avatars.discourse-cdn.com/v4/letter/a/ec9cab/32.png) [@anandnsingh](https://discuss.elastic.co/u/anandnsingh)\
**Post date:** [January 15, 2016, 6:10pm UTC](https://discuss.elastic.co/t/where-to-drop-jar-containing-custome-plugin-or-encoder-like-custom-kafka-message-decoder/39190/5 "2016-01-15T18:10:17Z")

</div>

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 ?

---

_[View the full topic](https://discuss.elastic.co/t/where-to-drop-jar-containing-custome-plugin-or-encoder-like-custom-kafka-message-decoder/39190)._