Logstash Kafka SASL_PLAIN input plugin config

I have been trying to connect logstash to my remote kafka instance, which has SASL_PLAIN authentication method, but still not able establish the connection and getting the following error :
org.apache.kafka.clients.NetworkClient][main] Bootstrap broker HOST:PORT (id: -1 rack: null) disconnected.
What is the right config of logstash input for connecting to remote kafka, which is of SASL_PLAIN authentication. I've gone through the documentation and didn't found any thing around this config.
I'm using logstash of version 7.17

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