Hi, I'm using KafkaSpout wiht new kafka consumer api. I'm also trying to connect kakfa with SSL authentication.
I create a KafkaSpoutConfig object, and call setSSLKeystore(keysotre_location, keystore_password) and setSSLTrustsotre(keystore_location) method to set "ssl.keystore.location" and "ssl.truststore.location" of kafka consumer properties. I package the keystore file and truststore file in resources directory into the jar. However, kafka consumer cannot find the files when topology running on the cluster. I find "ssl.keystore.location" and "ssl.truststore.location" is set to local directory where I submit the topology, not the storm workers. So what should keysotre_locatin and truststore_location be if I put keystore file and truststore file in resources directory? -- Thanks Zhechao Ma
