# Logstash error - bootstrap broker disconnected
**URL:** https://discuss.elastic.co/t/logstash-error-bootstrap-broker-disconnected/245965
**Category:** Logstash
**Created:** [August 21, 2020, 11:18pm UTC](https://discuss.elastic.co/t/logstash-error-bootstrap-broker-disconnected/245965 "2020-08-21T23:18:32Z")
**Posts on this page:** 3
**Page:** 1
### Author:  [@chandramouli\_sriniva](https://discuss.elastic.co/u/chandramouli_sriniva)
#### Post date: [August 21, 2020, 11:18pm UTC](https://discuss.elastic.co/t/logstash-error-bootstrap-broker-disconnected/245965/1 "2020-08-21T23:18:33Z")
we are sending logs from file.txt to Kafka(SASL\_SSL with kerberos). Below are the parm being set in conf file:
```
bootstrap_servers => "broker:9093"
codec => json
topic_id => "topic"
jaas_path => "jaas.conf"
kerberos_config => "krb5.conf"
sasl_kerberos_service_name => "kafka"
sasl_mechanism => "GSSAPI"
security_protocol => "SASL_SSL"
ssl_endpoint_identification_algorithm => "https"
ssl_key_password => ""
ssl_keystore_location => "jks"
ssl_keystore_password => ""
ssl_keystore_type => "JKS"
ssl_truststore_location => "jks"
ssl_truststore_password => ""
ssl_truststore_type => "JKS"
```
Let me know If I miss any parameter.
when I run logstash, I get "boostrap broker disconnected" error from logstash. From kafka I see below error
[2020-08-21 23:04:46,160] INFO Successfully authenticated client: [authenticationID=abc@REALM.COM](mailto:authenticationID=abc@REALM.COM);
org.apache.kafka.common.KafkaException: Failed to set name for 'domain@REALM' based on Kerberos authentication rules.
at org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder.applyKerberosShortNamer(DefaultKafkaPrincipalBuilder.java:142)
at org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder.build(DefaultKafkaPrincipalBuilder.java:128)
at org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.principal(SaslServerAuthenticator.java:292)
at org.apache.kafka.common.network.KafkaChannel.principal(KafkaChannel.java:162)
at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:888)
at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:871)
at scala.collection.Iterator.foreach(Iterator.scala:941)
at scala.collection.Iterator.foreach$(Iterator.scala:941)
.......
Caused by: org.apache.kafka.common.security.kerberos.NoMatchingRule: No rules apply to domain@REALM, rules
at org.apache.kafka.common.security.kerberos.KerberosShortNamer.shortName(KerberosShortNamer.java:98)
Any leads appreciated. Thanks.
---
### Author:  [@Badger](https://discuss.elastic.co/u/Badger)
#### Post date: [August 21, 2020, 11:31pm UTC](https://discuss.elastic.co/t/logstash-error-bootstrap-broker-disconnected/245965/2 "2020-08-21T23:31:53Z")
> [@chandramouli\_sriniva](#):
>
> Caused by: org.apache.kafka.common.security.kerberos.NoMatchingRule: No rules apply to domain@REALM, rules
> at org.apache.kafka.common.security.kerberos.KerberosShortNamer.shortName(KerberosShortNamer.java:98)
The [code](https://github.com/a0x8o/kafka/blob/822f34e32a7b21652abad78cbe22ff44ef8ee6d3/clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java#L83) is trying to map a Kerberos principal name into an operating system user name.
I would guess that you need to set sasl.kerberos.service.name somewhere, but what you have here is really a Kafka question, not a logstash question.
---
### Author:  [@system](https://discuss.elastic.co/u/system)
#### Post date: [September 18, 2020, 11:32pm UTC](https://discuss.elastic.co/t/logstash-error-bootstrap-broker-disconnected/245965/3 "2020-09-18T23:32:12Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.