If Kafka is configured with SASL / SCRAM, then Druid, which is the Kafka consumer, should pass the SASL / SCRAM credentials in the consumerProperties block of ioConfig section of the Kafka supervisor spec:
"ioConfig": {
"topic": "some_topic",
"consumerProperties": {
"bootstrap.servers": "host1:9092,host2:9092,host3:9092",
"sasl.mechanism": "SCRAM-SHA-256",
"security.protocol": "SASL_SSL",
"sasl.jaas.config": "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"some_userID\" password=\"some_password\";"
}
"taskCount": 1,
"replicas": 1,
"taskDuration": "PT1H"
}
Comments
0 comments
Please sign in to leave a comment.