node.js - KafkaJS 生产者 ssl 证书

Question

我正在使用 KafkaJS 编写 NodeJS Kafka 生产者，并且无法理解如何获取所需的 SSL 证书以便使用 SASL-SSL 连接连接到 Kafka。
在 KafkaJS 文档中，SSL 有以下配置:

ssl: {
    rejectUnauthorized: false,
    ca: [fs.readFileSync('/my/custom/ca.crt', 'utf-8')],
    key: fs.readFileSync('/my/custom/client-key.pem', 'utf-8'),
    cert: fs.readFileSync('/my/custom/client-cert.pem', 'utf-8')
  },

我有问题，因为我不知道我应该如何/提供什么证书给它。

我需要提供所有三个 Prop (ca、key 和 cert)吗？如果是这样如何获得它们？我们有这样配置的 Kafka 集群 Confluent Security Tutorial
我是否必须解码 keystore 或其他东西才能为我的 KafkaJS 获取适当的证书
制片人？我对这一切只有一点了解。

Answer 1

您的代理是否强制执行客户端身份验证？如果是，那么您将需要 key和 cert .如果您的客户端在“标准”计算机上运行，​​那么大多数众所周知的 CA 将已经存在，例如在 /etc/ssl/certs .在这种情况下，您只需要 ssl : true .如果您使用的是自签名证书而不是客户端身份验证，那么 ca需要提供。

所以，这里是你的选择。

客户端认证

如果 CA 是自签名的，则添加 ca也(见下文)。

ssl: {
    key: fs.readFileSync('/my/custom/client-key.pem', 'utf-8'),
    cert: fs.readFileSync('/my/custom/client-cert.pem', 'utf-8')
  }

自签名证书

ssl: {
    rejectUnauthorized: false,
    ca: [fs.readFileSync('/my/custom/ca.crt', 'utf-8')]
  }

rejectUnauthorized : false不会检查已知 CA。

看到这个 SO question了解更多信息。