# Logstash Kafka Input Plugin Throws Errors missing class name (\`org.apache.kafka.clients.consumer.ConsumerConfig')

**URL:** https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128
**Category:** Logstash
**Created:** [October 24, 2017, 9:26pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128 "2017-10-24T21:26:43Z")
**Posts on this page:** 5
**Page:** 1

<div class="post-metadata">

### Author: ![Randall\_Svancara](https://avatars.discourse-cdn.com/v4/letter/r/5fc32e/32.png) [@Randall\_Svancara](https://discuss.elastic.co/u/Randall_Svancara)
#### Post date: [October 24, 2017, 9:26pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128/1 "2017-10-24T21:26:43Z")

</div>

I would really like to use this input plug-in but in the time I have spent futzing around with it I could of written something in GoLang.....The problem is that no matter what I do the plugin does not load:

- Version:  
Logstash -\> ii logstash 1:5.6.3-1 all An extensible logging pipeline  
Logstash Input Module -\> logstash-input-kafka-8.0.2

- Operating System:  
Ubuntu Xenial, 16.04

- Config File (if you have sensitive info, please remove it):  
input {  
kafka {  
bootstrap\_servers =\> "kafka-node:9092"  
topics =\> ["topic1","topic2","topic3"]  
}  
}

output {  
tcp {  
host =\> "10.155.24.23"  
port =\> "5044"  
}  
}

- Sample Data:

- Steps to Reproduce:

1. Start kafka,
2. Watch the logs

[2017-10-24T21:23:39,678][ERROR][logstash.pipeline] A plugin had an unrecoverable error. Will restart this plugin.  
Plugin: \<LogStash::Inputs::Kafka bootstrap\_servers=\>"kafka-seed1.us-west-2.ec2.pages:9092", topics=\>["prod.edn.wp-msg-fraudengine-transactions", "prod.log.access-prod-POD", "prod.log.access-prod-identity-check-ng", "prod.log.artifactory", "prod.log.auth"], id=\>"8eaa3093e674018d54f6b047b26741246ace3ed7-1", enable\_metric=\>true, codec=\>\<LogStash::Codecs::Plain id=\>"plain\_3edbae47-994c-4e6a-bc3a-e9e7a643d4f7", enable\_metric=\>true, charset=\>"UTF-8"\>, auto\_commit\_interval\_ms=\>"5000", client\_id=\>"logstash", consumer\_threads=\>1, enable\_auto\_commit=\>"true", group\_id=\>"logstash", key\_deserializer\_class=\>"org.apache.kafka.common.serialization.StringDeserializer", value\_deserializer\_class=\>"org.apache.kafka.common.serialization.StringDeserializer", poll\_timeout\_ms=\>100, security\_protocol=\>"PLAINTEXT", sasl\_mechanism=\>"GSSAPI", decorate\_events=\>false\>  
Error: uncaught throw missing class name (`org.apache.kafka.clients.consumer.ConsumerConfig') in thread 0x1d6c28e2

- Version:  
Logstash -\> ii logstash 1:5.6.3-1 all An extensible logging pipeline  
Logstash Input Module -\> logstash-input-kafka-8.0.2

- Operating System:  
Ubuntu Xenial, 16.04

- Config File (if you have sensitive info, please remove it):  
input {  
kafka {  
bootstrap\_servers =\> "kafka-node:9092"  
topics =\> ["topic1","topic2","topic3"]  
}  
}

output {  
tcp {  
host =\> "10.155.24.23"  
port =\> "5044"  
}  
}

- Sample Data:

- Steps to Reproduce:

1. Start kafka,
2. Watch the logs

[2017-10-24T21:23:39,678][ERROR][logstash.pipeline] A plugin had an unrecoverable error. Will restart this plugin.  
Plugin: \<LogStash::Inputs::Kafka bootstrap\_servers=\>"kafka-seed1.us-west-2.ec2.pages:9092", topics=\>["prod.edn.wp-msg-fraudengine-transactions", "prod.log.access-prod-POD", "prod.log.access-prod-identity-check-ng", "prod.log.artifactory", "prod.log.auth"], id=\>"8eaa3093e674018d54f6b047b26741246ace3ed7-1", enable\_metric=\>true, codec=\>\<LogStash::Codecs::Plain id=\>"plain\_3edbae47-994c-4e6a-bc3a-e9e7a643d4f7", enable\_metric=\>true, charset=\>"UTF-8"\>, auto\_commit\_interval\_ms=\>"5000", client\_id=\>"logstash", consumer\_threads=\>1, enable\_auto\_commit=\>"true", group\_id=\>"logstash", key\_deserializer\_class=\>"org.apache.kafka.common.serialization.StringDeserializer", value\_deserializer\_class=\>"org.apache.kafka.common.serialization.StringDeserializer", poll\_timeout\_ms=\>100, security\_protocol=\>"PLAINTEXT", sasl\_mechanism=\>"GSSAPI", decorate\_events=\>false\>  
Error: uncaught throw missing class name (`org.apache.kafka.clients.consumer.ConsumerConfig') in thread 0x1d6c28e2

---

<div class="post-metadata">

### Author: ![Randall\_Svancara](https://avatars.discourse-cdn.com/v4/letter/r/5fc32e/32.png) [@Randall\_Svancara](https://discuss.elastic.co/u/Randall_Svancara)
#### Post date: [October 24, 2017, 9:29pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128/2 "2017-10-24T21:29:25Z")

</div>

Attempted to reinstall everything!

apt-get purge logstash

Then remove all the left over directories, and then re-install

THIS DID NOT RESOLVE THE PROBLEM

---

<div class="post-metadata">

### Author: ![Randall\_Svancara](https://avatars.discourse-cdn.com/v4/letter/r/5fc32e/32.png) [@Randall\_Svancara](https://discuss.elastic.co/u/Randall_Svancara)
#### Post date: [October 24, 2017, 10:12pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128/3 "2017-10-24T22:12:01Z")

</div>

Attempted to update the plugin...alas...this does not work either. Does not work with the reinstall.

---

<div class="post-metadata">

### Author: ![Randall\_Svancara](https://avatars.discourse-cdn.com/v4/letter/r/5fc32e/32.png) [@Randall\_Svancara](https://discuss.elastic.co/u/Randall_Svancara)
#### Post date: [October 24, 2017, 10:22pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128/4 "2017-10-24T22:22:27Z")

</div>

This is so overly descriptive:

[2017-10-24T22:21:30,111][ERROR][logstash.inputs.kafka] Unable to create Kafka consumer from given configuration {:kafka\_error\_message=\>#\<NameError: missing class name (`org.apache.kafka.clients.consumer.ConsumerConfig')\>, :cause=\>nil}

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)
#### Post date: [November 21, 2017, 10:22pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-throws-errors-missing-class-name-org-apache-kafka-clients-consumer-consumerconfig/105128/5 "2017-11-21T22:22:34Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.