This message was deleted.

I'm on Druid 0.23.0 & Kafka 3.0.0 and a supervisor with this config:

"ioConfig": {
      "topic": "<topic>",
      "consumerProperties": {
        "bootstrap.servers": "<server:port>",
        "sasl.mechanism": "SCRAM-SHA-512",
        "security.protocol": "SASL_PLAINTEXT",
        "sasl.jaas.config": "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"<user>\" password=\"<passsword>\";"
      },
...

But I can't establish connection

Connection to node -1 (<http://kafka-bootstrap.emea.polynet.sta.s73cloud.com/18.202.37.218:443|kafka-bootstrap.emea.polynet.sta.s73cloud.com/18.202.37.218:443>) 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.

I think it should work out of the box . Sample PLAIN SASL with SSL

"consumerProperties": {

"security.protocol": "SASL_SSL",

"sasl.mechanism": "PLAIN",

"sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"xx\" password=\"xx\";",

"bootstrap.servers": "xxx:9092"

},

Thanks for you help @Karan Kumar but I'm not using certs because I'm setting

"security.protocol": "SASL_PLAINTEXT",