c# - 如何将 confluent-kafka 与 key 存储文件一起使用

Question

当我使用 key 存储文件时，添加属性

ssl.keystore.location
ssl.keystore.password
ssl.key.password
ssl.truststore.location
ssl.truststore.password

在配置中，它抛出这个错误:

Can not find the property ssl.truststore.location"

如何将 librdkafka 与 key 存储文件一起使用？很困扰我，有谁知道如何将 confluent-kafka 与 key 存储文件一起使用吗？

融合卡夫卡:https://github.com/confluentinc/confluent-kafka-dotnet/

遵循 CONFIGURATION.md: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md

我在 CONFIGURATION.md 中找不到该属性

Answer 1

ssl.keystore.* 和 ssl.truststore.* 是 Java 客户端属性，它们使用 Java 的 JAAS 框架和 Java 特定的信任/ keystore 。

librdkafka(及其同级客户端)使用使用 PEM 和证书文件格式的 OpenSSL。

请参阅本指南如何设置它: https://github.com/edenhill/librdkafka/wiki/Using-SSL-with-librdkafka

这个 SO 问题解释了如何将 keystore 转换为 OpenSSL 文件类型: Converting a Java Keystore into PEM Format