# Logstash kafka input problem(Unable to create Kafka consumer from given configuration ) **URL:** \ **Category:** Logstash\ **Created:** [April 25, 2019, 6:21am UTC](https://discuss.elastic.co/t/logstash-kafka-input-problem-unable-to-create-kafka-consumer-from-given-configuration/178373 "2019-04-25T06:21:54Z")\ **Posts on this page:** 3\ **Page:** 1
**Author:** ![ahmetkumas1](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/ahmetkumas1/32/44691_2.png) [@ahmetkumas1](https://discuss.elastic.co/u/ahmetkumas1)\ **Post date:** [April 25, 2019, 6:21am UTC](https://discuss.elastic.co/t/logstash-kafka-input-problem-unable-to-create-kafka-consumer-from-given-configuration/178373/1 "2019-04-25T06:21:55Z")
Hello everyone, I'm having trouble with logstash when I want to use logstash to log kafka topics here is the full output. ``` [2019-04-25T09:21:18,836][WARN][org.apache.kafka.clients.ClientUtils] Couldn't resolve server localhosts:9093 from bootstrap.servers as DNS resolution failed for localhosts ``` [2019-04-25T09:21:18,850][ERROR][logstash.inputs.kafka] Unable to create Kafka consumer from given configuration {:kafka\_error\_message=\>org.apache.kafka.common.KafkaException: Failed to construct kafka consumer, :cause=\>org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers} [2019-04-25T09:21:18,853][ERROR][logstash.pipeline] A plugin had an unrecoverable error. Will restart this plugin. Pipeline\_id:main Plugin: \"localhosts:9093", topics=\>["cars"], id=\>"fe6887996428551d58c1bacd44eae84a09ad59bad2652cca2a7f665bda1323af", enable\_metric=\>true, codec=\>\"plain\_69d42d93-f326-4a7f-9214-b44b11bd3ad4", 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, ssl\_endpoint\_identification\_algorithm=\>"https", security\_protocol=\>"PLAINTEXT", sasl\_mechanism=\>"GSSAPI", decorate\_events=\>false\> Error: Failed to construct kafka consumer Exception: Java::OrgApacheKafkaCommon::KafkaException Stack: org.apache.kafka.clients.consumer.KafkaConsumer.(org/apache/kafka/clients/consumer/KafkaConsumer.java:805) org.apache.kafka.clients.consumer.KafkaConsumer.(org/apache/kafka/clients/consumer/KafkaConsumer.java:652) org.apache.kafka.clients.consumer.KafkaConsumer.(org/apache/kafka/clients/consumer/KafkaConsumer.java:632) java.lang.reflect.Constructor.newInstance(java/lang/reflect/Constructor) org.jruby.javasupport.JavaConstructor.newInstanceDirect(org/jruby/javasupport/JavaConstructor.java:278) org.jruby.RubyClass.newInstance(org/jruby/RubyClass.java:1001) org.jruby.RubyClass$INVOKER$i$newInstance.call(org/jruby/RubyClass$INVOKER$i$newInstance.gen) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.vendor.bundle.jruby.$2\_dot\_3\_dot\_0.gems.logstash\_minus\_input\_minus\_kafka\_minus\_8\_dot\_3\_dot\_1.lib.logstash.inputs.kafka.create\_consumer(C:/Users/akumas/Desktop/logstash-6.6.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.3.1/lib/logstash/inputs/kafka.rb:328) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.vendor.bundle.jruby.$2\_dot\_3\_dot\_0.gems.logstash\_minus\_input\_minus\_kafka\_minus\_8\_dot\_3\_dot\_1.lib.logstash.inputs.kafka.block in run(C:/Users/akumas/Desktop/logstash-6.6.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.3.1/lib/logstash/inputs/kafka.rb:226) org.jruby.RubyEnumerable$23.call(org/jruby/RubyEnumerable.java:846) org.jruby.RubyFixnum.times(org/jruby/RubyFixnum.java:305) org.jruby.RubyFixnum$INVOKER$i$0$0$times.call(org/jruby/RubyFixnum$INVOKER$i$0$0$times.gen) org.jruby.RubyClass.finvoke(org/jruby/RubyClass.java:522) org.jruby.RubyBasicObject.callMethod(org/jruby/RubyBasicObject.java:393) org.jruby.RubyEnumerator.each(org/jruby/RubyEnumerator.java:323) org.jruby.RubyEnumerator$INVOKER$i$each.call(org/jruby/RubyEnumerator$INVOKER$i$each.gen) org.jruby.RubyClass.finvoke(org/jruby/RubyClass.java:512) org.jruby.RubyEnumerable.callEach19(org/jruby/RubyEnumerable.java:116) org.jruby.RubyEnumerable.collectCommon(org/jruby/RubyEnumerable.java:838) org.jruby.RubyEnumerable.map(org/jruby/RubyEnumerable.java:830) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.vendor.bundle.jruby.$2\_dot\_3\_dot\_0.gems.logstash\_minus\_input\_minus\_kafka\_minus\_8\_dot\_3\_dot\_1.lib.logstash.inputs.kafka.run(C:/Users/akumas/Desktop/logstash-6.6.0/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.3.1/lib/logstash/inputs/kafka.rb:226) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.logstash\_minus\_core.lib.logstash.pipeline.inputworker(C:/Users/akumas/Desktop/logstash-6.6.0/logstash-core/lib/logstash/pipeline.rb:409) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.logstash\_minus\_core.lib.logstash.pipeline.RUBY$method$inputworker$0$ **VARARGS** (C\_3a\_/Users/akumas/Desktop/logstash\_minus\_6\_dot\_6\_dot\_0/logstash\_minus\_core/lib/logstash/C:/Users/akumas/Desktop/logstash-6.6.0/logstash-core/lib/logstash/pipeline.rb) C\_3a\_.Users.akumas.Desktop.logstash\_minus\_6\_dot\_6\_dot\_0.logstash\_minus\_core.lib.logstash.pipeline.block in start\_input(C:/Users/akumas/Desktop/logstash-6.6.0/logstash-core/lib/logstash/pipeline.rb:403) org.jruby.RubyProc.call(org/jruby/RubyProc.java:289) org.jruby.RubyProc.call(org/jruby/RubyProc.java:246) java.lang.Thread.run(java/lang/Thread) and this is my config file; input{ kafka{ bootstrap\_servers =\>"localhosts:9093" topics =\> ["cars"] ``` } ``` } filter{ csv { separator =\>"," ``` columns => ["maker", "model", "mileage", "manufacture_year", "engine_displacement", "engine_power", "body_type", "color_slug", "stk_year", "transmission", "door_count", "seat_count", "fuel_type", "date_created", "date_last_seen", "price_eur"] } mutate {convert => ["mileage", "integer"] } mutate {convert => ["price_eur", "float"] } mutate {convert => ["engine_power", "integer"] } mutate {convert => ["door_power", "integer"] } mutate {convert => ["seat_count", "integer"] } ``` } output{ elasticsearch { hosts =\> "localhost" index =\> "cars" document\_type=\>"sold\_cars" } stdout{} } ---
**Author:** ![desnia\_ayu\_karlyna](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/desnia_ayu_karlyna/32/45317_2.png) [@desnia\_ayu\_karlyna](https://discuss.elastic.co/u/desnia_ayu_karlyna)\ **Post date:** [April 30, 2019, 11:38am UTC](https://discuss.elastic.co/t/logstash-kafka-input-problem-unable-to-create-kafka-consumer-from-given-configuration/178373/2 "2019-04-30T11:38:03Z")
it's a typo localhosts, should be localhost ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [May 28, 2019, 11:38am UTC](https://discuss.elastic.co/t/logstash-kafka-input-problem-unable-to-create-kafka-consumer-from-given-configuration/178373/3 "2019-05-28T11:38:12Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.