# Logstash started to crash trying to connect to Kafka

**URL:** <https://discuss.elastic.co/t/logstash-started-to-crash-trying-to-connect-to-kafka/193196>\
**Category:** Logstash\
**Created:** [July 31, 2019, 6:03pm UTC](https://discuss.elastic.co/t/logstash-started-to-crash-trying-to-connect-to-kafka/193196 "2019-07-31T18:03:36Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![cyxop](https://avatars.discourse-cdn.com/v4/letter/c/9dc877/32.png) [@cyxop](https://discuss.elastic.co/u/cyxop)\
**Post date:** [July 31, 2019, 6:03pm UTC](https://discuss.elastic.co/t/logstash-started-to-crash-trying-to-connect-to-kafka/193196/1 "2019-07-31T18:03:36Z")

</div>

Version: logstash 5.6.5  
Plugin Version logstash-output-kafka  
Operating System: RHEL7

{code}  
[2019-07-31T17:43:04,243][INFO][org.apache.kafka.clients.producer.KafkaProducer] Closing the Kafka producer with timeoutMillis = 0 ms.  
[2019-07-31T17:43:04,248][ERROR][logstash.outputs.kafka] Unable to create Kafka producer from given configuration {:kafka\_error\_message=\>org.apache.kafka.common.KafkaException: Failed to construct kafka producer}  
[2019-07-31T17:43:04,260][ERROR][logstash.pipeline] Error registering plugin {:plugin=\>"#\<LogStash::OutputDelegator:0xe9afc99 @namespaced\_metric=#\<LogStash::Instrument::NamespacedMetric:0x684e19e9 @metric=#\<LogStash::Instrument::Metric:0x13f5368c @collector=#\<LogStash::Instrument::Collector:0x52537655 @agent=nil, @metric\_store=#\<LogStash::Instrument::MetricStore:0xb7436b2 @store=#\<Concurrent:🗺0x0000000006b8c8 entries=2 default\_proc=nil\>, @structured\_lookup\_mutex=#Mutex:0x13ede764, @fast\_lookup=#\<Concurrent:🗺0x0000000006b8cc entries=54 default\_proc=nil\>\>\>\>, @namespace\_name=[:stats, :pipelines, :main, :plugins, :outputs, :"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3"]\>, @metric=#\<LogStash::Instrument::NamespacedMetric:0x603ed86a @metric=#\<LogStash::Instrument::Metric:0x13f5368c @collector=#\<LogStash::Instrument::Collector:0x52537655 @agent=nil, @metric\_store=#\<LogStash::Instrument::MetricStore:0xb7436b2 @store=#\<Concurrent:🗺0x0000000006b8c8 entries=2 default\_proc=nil\>, @structured\_lookup\_mutex=#Mutex:0x13ede764, @fast\_lookup=#\<Concurrent:🗺0x0000000006b8cc entries=54 default\_proc=nil\>\>\>\>, @namespace\_name=[:stats, :pipelines, :main, :plugins, :outputs]\>, @logger=#\<LogStash::Logging::Logger:0x36ffbb90 @logger=#Java::OrgApacheLoggingLog4jCore::Logger:0x3ad80200\>, @out\_counter=LogStash::Instrument::MetricType::Counter - namespaces: [:stats, :pipelines, :main, :plugins, :outputs, :"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", :events] key: out value: 0, @in\_counter=LogStash::Instrument::MetricType::Counter - namespaces: [:stats, :pipelines, :main, :plugins, :outputs, :"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", :events] key: in value: 0, @strategy=#\<LogStash::OutputDelegatorStrategies::Shared:0x59a3154b @output=\<LogStash::Outputs::Kafka topic\_id=\>"test-dev", bootstrap\_servers=\>"[logakafka1-dev.test.net:9043](http://logakafka1-dev.test.net:9043),[logakafka2-dev.test.net:9043](http://logakafka2-dev.test.net:9043),[logakafka3-dev.test.net:9043](http://logakafka3-dev.test.net:9043)", codec=\>\<LogStash::Codecs::JSON id=\>"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-2", enable\_metric=\>true, charset=\>"UTF-8"\>, security\_protocol=\>"SSL", ssl\_keystore\_location=\>"/ssl/keystore/loga-dev.producer.jks", ssl\_truststore\_location=\>"/ssl/truststore/loga.client.truststore.jks", ssl\_keystore\_password=\>, ssl\_truststore\_password=\>, id=\>"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", enable\_metric=\>true, workers=\>1, acks=\>"1", batch\_size=\>16384, block\_on\_buffer\_full=\>true, buffer\_memory=\>33554432, compression\_type=\>"none", key\_serializer=\>"org.apache.kafka.common.serialization.StringSerializer", linger\_ms=\>0, max\_request\_size=\>1048576, metadata\_fetch\_timeout\_ms=\>60000, metadata\_max\_age\_ms=\>300000, receive\_buffer\_bytes=\>32768, reconnect\_backoff\_ms=\>10, retry\_backoff\_ms=\>100, send\_buffer\_bytes=\>131072, ssl=\>false, sasl\_mechanism=\>"GSSAPI", timeout\_ms=\>30000, value\_serializer=\>"org.apache.kafka.common.serialization.StringSerializer"\>\>, @id="0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", @time\_metric=LogStash::Instrument::MetricType::Counter - namespaces: [:stats, :pipelines, :main, :plugins, :outputs, :"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", :events] key: duration\_in\_millis value: 0, @metric\_events=#\<LogStash::Instrument::NamespacedMetric:0x12cb06d4 @metric=#\<LogStash::Instrument::Metric:0x13f5368c @collector=#\<LogStash::Instrument::Collector:0x52537655 @agent=nil, @metric\_store=#\<LogStash::Instrument::MetricStore:0xb7436b2 @store=#\<Concurrent:🗺0x0000000006b8c8 entries=2 default\_proc=nil\>, @structured\_lookup\_mutex=#Mutex:0x13ede764, @fast\_lookup=#\<Concurrent:🗺0x0000000006b8cc entries=54 default\_proc=nil\>\>\>\>, @namespace\_name=[:stats, :pipelines, :main, :plugins, :outputs, :"0ee478d8f9b8f2874e16e0bec48b99ffc8711c60-3", :events]\>, @output\_class=LogStash::Outputs::Kafka\>", :error=\>"Failed to construct kafka producer"}  
[2019-07-31T17:43:04,291][ERROR][logstash.agent] Pipeline aborted due to error {:exception=\>org.apache.kafka.common.KafkaException: Failed to construct kafka producer, :backtrace=\>["org.apache.kafka.clients.producer.KafkaProducer.(org/apache/kafka/clients/producer/KafkaProducer.java:335)", "org.apache.kafka.clients.producer.KafkaProducer.(org/apache/kafka/clients/producer/KafkaProducer.java:188)", "RUBY.create\_producer(/tools/logstash-5.6.5/vendor/bundle/jruby/1.9/gems/logstash-output-kafka-5.1.11/lib/logstash/outputs/kafka.rb:334)", "RUBY.register(/tools/logstash-5.6.5/vendor/bundle/jruby/1.9/gems/logstash-output-kafka-5.1.11/lib/logstash/outputs/kafka.rb:195)", "RUBY.register(/tools/logstash-5.6.5/logstash-core/lib/logstash/output\_delegator\_strategies/shared.rb:9)", "RUBY.register(/tools/logstash-5.6.5/logstash-core/lib/logstash/output\_delegator.rb:43)", "RUBY.register\_plugin(/tools/logstash-5.6.5/logstash-core/lib/logstash/pipeline.rb:290)", "RUBY.register\_plugins(/tools/logstash-5.6.5/logstash-core/lib/logstash/pipeline.rb:301)", "org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)", "RUBY.register\_plugins(/tools/logstash-5.6.5/logstash-core/lib/logstash/pipeline.rb:301)", "RUBY.start\_workers(/tools/logstash-5.6.5/logstash-core/lib/logstash/pipeline.rb:310)", "RUBY.run(/tools/logstash-5.6.5/logstash-core/lib/logstash/pipeline.rb:235)", "RUBY.start\_pipeline(/tools/logstash-5.6.5/logstash-core/lib/logstash/agent.rb:408)"]}  
[2019-07-31T17:43:04,364][INFO][logstash.agent] Successfully started Logstash API endpoint {:port=\>9600}  
[2019-07-31T17:43:07,333][WARN][logstash.agent] stopping pipeline {:id=\>"main"}  
{code}

---

<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:** [August 28, 2019, 6:03pm UTC](https://discuss.elastic.co/t/logstash-started-to-crash-trying-to-connect-to-kafka/193196/2 "2019-08-28T18:03:37Z")

</div>

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