Re: keystore location on EMR

2020-11-17 Thread Fanbin Bu
trying to put the jks on s3... unfortunately, no luck. i have properties set up: 'properties.ssl.keystore.location'='s3://application-bucket/kafka.keystore.jks' got the following error message: at org.apache.kafka.common.security.ssl.SslEngineBuilder$SecurityStore .load(SslEngineBuilder.java:

keystore location on EMR

2020-11-17 Thread Fanbin Bu
Hi, I'm running Flink 1.11 on EMR and would like to read Kafka via SSL. I tried to put keystore.jks location under /usr/lib/flink/... like: export SSL_KEYSTORE_LOCATION=/usr/lib/flink/kafka/kafka_2.11-2.3.1/config/ssl/keystore/kafka.keystore.jks Notice that this is on EMR master(master) node. Bo