# Issue Enable SASL Authentication for Kafka Output in Filebeat Configuration

**URL:** <https://discuss.elastic.co/t/issue-enable-sasl-authentication-for-kafka-output-in-filebeat-configuration/382827>\
**Category:** Beats\
**Created:** [October 20, 2025, 2:47am UTC](https://discuss.elastic.co/t/issue-enable-sasl-authentication-for-kafka-output-in-filebeat-configuration/382827 "2025-10-20T02:47:51Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Thirupathi](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/thirupathi/32/145431_2.png) [@Thirupathi](https://discuss.elastic.co/u/Thirupathi)\
**Post date:** [October 20, 2025, 2:47am UTC](https://discuss.elastic.co/t/issue-enable-sasl-authentication-for-kafka-output-in-filebeat-configuration/382827/1 "2025-10-20T02:47:51Z")

</div>

output.kafka:  
hosts: ["10.42.41.55:19094"]  
topic: 'npc-raw-msg'  
key: '%{[UUID]}'  
codec.format:  
string: '%{[message]}'  
partition.round\_robin:  
reachable\_only: false  
required\_acks: 1  
compression: gzip  
max\_message\_bytes: 1000000  
close\_inactive: 10m  
sasl.mechanism: SCRAM-SHA-512  
sasl.username: "test-user-ranjith"  
sasl.password: "xSBWc2w6NmkiPi4+YyBs"  
security.protocol: SASL\_PLAINTEXT

logging.level: debug  
logging.to\_files: true  
logging.files:  
path: /var/log/filebeat-kafka  
name: filebeat  
keepfiles: 7  
permissions: 0644

0400","log.logger":"publisher","log.origin":{"function":"[github.com/elastic/beats/v7/libbeat/publisher/pipeline.(\*queueReader).run","file.name":"pipeline/queue\_reader.go","file.line":54},"message":"pipeline](http://github.com/elastic/beats/v7/libbeat/publisher/pipeline.(*queueReader).run%22,%22file.name%22:%22pipeline/queue_reader.go%22,%22file.line%22:54%7D,%22message%22:%22pipeline) event consumer queue reader: stop","service.name":"filebeat","ecs.version":"1.6.0"}  
{"log.level":"error","@timestamp":"2025-10-09T05:54:05.051-0400","log.logger":"kafka","log.origin":{"function":"[github.com/elastic/beats/v7/libbeat/outputs/kafka.(\*client).errorWorker","file.name":"kafka/client.go","file.line":338},"message":"Ksettings](http://github.com/elastic/beats/v7/libbeat/outputs/kafka.(*client).errorWorker%22,%22file.name%22:%22kafka/client.go%22,%22file.line%22:338%7D,%22message%22:%22Ksettings))","service.name":"filebeat","ecs.version":"1.6.0"}  
{"log.level":"error","@timestamp":"2025-10-09T05:54:

---

<div class="post-metadata">

**Author:** ![TimV](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/timv/32/13162_2.png) [@TimV](https://discuss.elastic.co/u/TimV)\
**Post date:** [October 20, 2025, 7:00am UTC](https://discuss.elastic.co/t/issue-enable-sasl-authentication-for-kafka-output-in-filebeat-configuration/382827/2 "2025-10-20T07:00:06Z")

</div>

I've moved this to the beat forum - it's not an Elasticsearch issue.