# Logstash input with Kerberos Kafka Stream

**URL:** https://discuss.elastic.co/t/logstash-input-with-kerberos-kafka-stream/110202
**Category:** Logstash
**Created:** [December 4, 2017, 7:24pm UTC](https://discuss.elastic.co/t/logstash-input-with-kerberos-kafka-stream/110202 "2017-12-04T19:24:58Z")
**Posts on this page:** 2
**Page:** 1

<div class="post-metadata">

### Author: ![vmandulapalli](https://avatars.discourse-cdn.com/v4/letter/v/7c8e57/32.png) [@vmandulapalli](https://discuss.elastic.co/u/vmandulapalli)
#### Post date: [December 4, 2017, 7:24pm UTC](https://discuss.elastic.co/t/logstash-input-with-kerberos-kafka-stream/110202/1 "2017-12-04T19:24:58Z")

</div>

Hi,

I'm trying to create a logstash pipeline with kafka input plugin, kafka streams are protected with kerberos security. Provided configuration settings for jaas.conf, krb5.conf, and .keytab file, getting below error. 'Trace' on doesn't help much with the error message.

Any ideas?

[2017-12-04T19:09:23,733][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.KafkaException: javax.security.auth.login.LoginException: Not closed}

---

<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: [January 1, 2018, 7:25pm UTC](https://discuss.elastic.co/t/logstash-input-with-kerberos-kafka-stream/110202/2 "2018-01-01T19:25:02Z")

</div>

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