Flink Kafka 连接器 SSL 支持

【问题标题】：Flink Kafka Connector SSL SupportFlink Kafka 连接器 SSL 支持
【发布时间】：2019-08-14 11:11:07
【问题描述】：

我们的生产环境中有一个安全的 Kafka 集群（使用 TLS 加密、基于证书的客户端身份验证和 ACL）。我试图弄清楚如何使用适当的设置配置 Flink Kafka 连接器，以便它可以安全地连接到我们的 Kafka 集群。这对 Flink 可行吗？我必须通过属性传递安全配置的东西吗？

我们的 Flink 集群在 Kubernetes (1.14.2) 上运行，并使用带有集成 kafka 连接器的最新 Flink 稳定版本 (v1.8)。

【问题讨论】：

标签： apache-flink flink-streaming

【解决方案1】：

在对文档进行了一番摆弄之后，我已经自己动手了。我现在在运行 helm 时在部署时提供所需的 Java 密钥库（我们通过 helm 图表部署整个 Flink 内容）。密钥库将采用 base64 编码并保存为 Kubernetes 机密。 taskmanager pod 将 secret 挂载到给定位置。

我现在可以在运行 Flink 作业时在命令行上将密钥库/信任库的位置及其密码作为参数传递。这些参数最终用于通过属性配置 Kafka 客户端。

【讨论】：