# Not able to connect Kafka server in output kafka plugin using SASL\_SSL

**URL:** https://discuss.elastic.co/t/not-able-to-connect-kafka-server-in-output-kafka-plugin-using-sasl-ssl/318062
**Category:** Logstash
**Created:** [November 3, 2022, 3:53am UTC](https://discuss.elastic.co/t/not-able-to-connect-kafka-server-in-output-kafka-plugin-using-sasl-ssl/318062 "2022-11-03T03:53:23Z")
**Posts on this page:** 2
**Page:** 1

<div class="post-metadata">

### Author: ![danishbit09](https://avatars.discourse-cdn.com/v4/letter/d/ea5d25/32.png) [@danishbit09](https://discuss.elastic.co/u/danishbit09)
#### Post date: [November 3, 2022, 3:53am UTC](https://discuss.elastic.co/t/not-able-to-connect-kafka-server-in-output-kafka-plugin-using-sasl-ssl/318062/1 "2022-11-03T03:53:23Z")

</div>

I am not able to publish log into Kafka topic. Below error is showing. Kindly suggest for the below error log.

be removed in future version. Please use 'use\_all\_dns\_ips' or another non-deprecated value.  
[2022-11-03T11:05:59,074][INFO][org.apache.kafka.clients.producer.ProducerConfig][test] ProducerConfig values:  
acks = 1  
batch.size = 16384  
bootstrap.servers = [MyServer1:MyPort, MyServer1:MyPort2, MyServer1:MyPort3]  
buffer.memory = 33554432  
client.dns.lookup = default  
client.id = Client\_1  
compression.type = none  
connections.max.idle.ms = 540000  
delivery.timeout.ms = 120000  
enable.idempotence = false  
interceptor.classes =   
internal.auto.downgrade.txn.commit = false  
key.serializer = class org.apache.kafka.common.serialization.StringSerializer  
linger.ms = 0  
max.block.ms = 60000  
max.in.flight.requests.per.connection = 5  
max.request.size = 1048576  
metadata.max.age.ms = 300000  
metadata.max.idle.ms = 300000  
metric.reporters =   
metrics.num.samples = 2  
metrics.recording.level = INFO  
metrics.sample.window.ms = 30000  
partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner  
receive.buffer.bytes = 32768  
reconnect.backoff.max.ms = 50  
reconnect.backoff.ms = 50  
request.timeout.ms = 40000  
retries = 2147483647  
retry.backoff.ms = 100  
sasl.client.callback.handler.class = null  
sasl.jaas.config = null  
sasl.kerberos.kinit.cmd = /usr/bin/kinit  
sasl.kerberos.min.time.before.relogin = 60000  
sasl.kerberos.service.name = kafka  
sasl.kerberos.ticket.renew.jitter = 0.05  
sasl.kerberos.ticket.renew.window.factor = 0.8  
sasl.login.callback.handler.class = null  
sasl.login.class = null  
sasl.login.refresh.buffer.seconds = 300  
sasl.login.refresh.min.period.seconds = 60  
sasl.login.refresh.window.factor = 0.8  
sasl.login.refresh.window.jitter = 0.05  
sasl.mechanism = GSSAPI  
security.protocol = SASL\_SSL  
security.providers = null  
send.buffer.bytes = 131072  
socket.connection.setup.timeout.max.ms = 30000  
socket.connection.setup.timeout.ms = 10000  
ssl.cipher.suites = null  
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]  
ssl.endpoint.identification.algorithm = https  
ssl.engine.factory.class = null  
ssl.key.password = [hidden]  
ssl.keymanager.algorithm = SunX509  
ssl.keystore.certificate.chain = null  
ssl.keystore.key = null  
ssl.keystore.location = /logstash/logstash-8.4.3/config/kafka-client.truststore.jks  
ssl.keystore.password = [hidden]  
ssl.keystore.type = JKS  
ssl.protocol = TLSv1.3  
ssl.provider = null  
ssl.secure.random.implementation = null  
ssl.trustmanager.algorithm = PKIX  
ssl.truststore.certificates = null  
ssl.truststore.location = /logstash/logstash-8.4.3/config/kafka-client.truststore.jks  
ssl.truststore.password = [hidden]  
ssl.truststore.type = JKS  
transaction.timeout.ms = 60000  
transactional.id = null  
value.serializer = class org.apache.kafka.common.serialization.StringSerializer

Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /logstash/logstash-8.4.3/config/mykeytab.keytab refreshKrb5Config is false principal is [abc@Mydomain.com](mailto:abc@Mydomain.com) tryFirstPass is false useFirstPass is false storePass is false clearPass is false  
principal is [abc@Mydomain.com](mailto:abc@Mydomain.com)  
Will use keytab  
Commit Succeeded

[2022-11-03T11:05:59,600][INFO][org.apache.kafka.common.security.authenticator.AbstractLogin][test] Successfully logged in.  
[2022-11-03T11:05:59,602][INFO][org.apache.kafka.common.security.kerberos.KerberosLogin][test] [Principal=abc@Mydomain.com]: TGT refresh thread started.  
[2022-11-03T11:05:59,603][INFO][org.apache.kafka.common.security.kerberos.KerberosLogin][test] [Principal=abc@Mydomain.com]: TGT valid starting at: 2022-11-03T11:05:59.000+0800  
[2022-11-03T11:05:59,604][INFO][org.apache.kafka.common.security.kerberos.KerberosLogin][test] [Principal=abc@Mydomain.com]: TGT expires: 2022-11-03T21:05:59.000+0800  
[2022-11-03T11:05:59,604][INFO][org.apache.kafka.common.security.kerberos.KerberosLogin][test] [Principal=abc@Mydomain.com]: TGT refresh sleeping until: 2022-11-03T19:24:12.106+0800  
[2022-11-03T11:05:59,648][INFO][org.apache.kafka.common.utils.AppInfoParser][test] Kafka version: 2.8.1  
[2022-11-03T11:05:59,648][INFO][org.apache.kafka.common.utils.AppInfoParser][test] Kafka commitId: 839b886f9b732b15  
[2022-11-03T11:05:59,648][INFO][org.apache.kafka.common.utils.AppInfoParser][test] Kafka startTimeMs: 1667444759646  
[2022-11-03T11:05:59,660][WARN][logstash.filters.grok][test] ECS v8 support is a preview of the unreleased ECS v8, and uses the v1 patterns. When Version 8 of the Elastic Common Schema becomes available, this plugin will need to be updated  
[2022-11-03T11:05:59,825][WARN][logstash.javapipeline][test] 'pipeline.ordered' is enabled and is likely less efficient, consider disabling if preserving event order is not necessary  
[2022-11-03T11:05:59,904][INFO][logstash.javapipeline][test] Starting pipeline {:pipeline\_id=\>"test", "pipeline.workers"=\>1, "pipeline.batch.size"=\>1, "pipeline.batch.delay"=\>50, "pipeline.max\_inflight"=\>1, "pipeline.sources"=\>["/logstash/logstash-8.4.3/logstash.conf"], :thread=\>"#\<Thread:0xa045e77 run\>"}  
[2022-11-03T11:06:00,234][WARN][org.apache.kafka.clients.NetworkClient][test] [Producer clientId=Client\_1] Connection to node -3 (MyServer1:MyPort) terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.  
[2022-11-03T11:06:00,235][WARN][org.apache.kafka.clients.NetworkClient][test] [Producer clientId=Client\_1] Bootstrap broker MyServer1:MyPort (id: -3 rack: null) disconnected

---

<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: [December 1, 2022, 3:53am UTC](https://discuss.elastic.co/t/not-able-to-connect-kafka-server-in-output-kafka-plugin-using-sasl-ssl/318062/2 "2022-12-01T03:53:53Z")

</div>

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