I'm trying to figure out a way to make Flink jobmanager (in HA) connect to
zookeeper over SSL/TLS. It doesn't seem like there are native properties
like Kafka has that support this interaction yet. Is this true or is there
some way that I can go about doing this?
I'm trying to figure out a way to make Flink jobmanager (in HA) connect to
zookeeper over SSL/TLS. It doesn't seem like there are native properties
like Kafka has that support this interaction yet. Is this true or is there
some way that I can go about doing this?
Hi Azeem,
I haven't worked with Flink's SSL support, yet. But have you taken a look
at the SSL configuration options listed under [1]?
Best,
Matthias
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/security/security-ssl.html#complete-list-of-ssl-options
On Tue, Dec 8,
Hey Matthias,
I have and it doesn't seem like there are any native properties
that support this interaction. I did try enabling the rest/internal SSL
properties to see if that would work but when my jobmanager tries to make a
connection to zookeeper, zookeeper is rejecting the connection saying it
Hey Azeem,
I haven't tried this myself, but from the code / documentation, this could
work:
Flink ships with ZK 3.4 by default. You need to remove the ZK3.4 jar file
from the lib/ folder and add the ZK3.5 file from opt/ to lib/.
According to this guide, you could try passing the SSL configuratio
