有任何 [SingleStore] 用户吗?
为了为 Kafka 管道启用 SSL 加密(仅),我们创建了如下管道:
CREATE PIPELINE `kafka_ssl`
AS LOAD DATA KAFKA '<kafka-host>:<kafka-port>/test'
CONFIG '{"security.protocol": "ssl"
"ssl.ca.location": "<path-to-the-ca-certificate>"}''
INTO table <t>;
来自https://docs.memsql.com/v7.0/concepts/pipelines/kafka-kerberos-ssl/ 22
请注意,我们不是在寻找客户端身份验证(双向 TLS 连接)。这需要我们手动将 CA 证书复制到 memsql 节点并提供该路径。这适用于独立的 Kafka 集群。
如果我们使用 AWS MSK,推荐的方法是什么?
以下文档指向 MSK 客户端的 SSL 加密客户端配置。他们使用客户端信任库位置作为属性,该属性不是 memsql 管道配置 json 的标识属性
https://docs.aws.amazon.com/msk/latest/developerguide/msk-encryption.html 10 https://docs.aws.amazon.com/msk/latest/developerguide/msk-authentication.html
在 SingleStore 论坛中查看其他有相同问题的人。无法创建从 Singlestore in a box 到 AWS MSK 的管道。