@Kevin.Herron we’ve been asked to switch an original kafka consumer over from non-ssl to SSL and the function for SSL in this library aren’t working for me but I think I know why, I just would like some confirmation.
In the function below, I can see that the file “ssl” exists on the VM:
private static Properties getSSLProps(Properties props) ....... props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG,homePath+String.format("%swebserver%sssl.key",sep,sep,sep));
However, for the following file, the name seems wrong (“cert-chain-store” instead of “truststore”)
// Truststore settings String truststorePath = homePath+String.format("%sdata%scertificates%struststore.jks",sep,sep,sep);
Then when looking at the log, I can see that the trust store location null
So it seems to me that what I should be doing is changing truststore.jks to cert_chain_store.jks.
Does that seem correct or am I missing something?