Hi Adrian gay,
I think you can specify the above details in the Kafka consumer property of the Kafka supervisor specs :
A map of properties to be passed to the Kafka consumer. This must contain a property bootstrap.servers with a list of Kafka brokers in the form: <BROKER_1>:<PORT_1>,<BROKER_2>:<PORT_2>,...
For SSL connections, the keystore, truststore and key passwords can be provided as a Password Provider or String password.
eg :
},
"ioConfig": {
"topic": "TOPIC_NAME",
"replicas": 1,
"taskCount": 9,
"taskDuration": "PT3600S",
"consumerProperties": {
"ssl.keystore.location": "<KEYSTORE PATH>/keystoreFile.jks",
"ssl.key.password": "$PassWord",
"bootstrap.servers": "<SERVER>:<PORT>",
"security.protocol": "SSL",
"ssl.truststore.location": "<TRUSTSTORE PATH>/truststoreFile.jks",
"ssl.keystore.password": "PassWord",
"ssl.truststore.password": "PassWord"
},
Hope this helps.
Thanks and Regards,
Vaibhav