我正在尝试通过 SSL 从 .net 客户端(Confluent.Kafka 0.9.4)连接到 kafka 代理,但得到 AccessViolationException : Attempted to read or write protected memory。这通常表明其他内存已损坏。使用的配置:
{
{"group.id", kafkaGroup},
{"client.id", clientId},
{"bootstrap.servers", kafkaServer},
{"enable.auto.commit", true},
{"security.protocol", "ssl" },
{"ssl.key.location", "sslkey/client.keystore.jks"},
{ "ssl.key.password", "testtest" },
{ "auto.commit.interval.ms", 5000},
{ "default.topic.config", new Dictionary<string, object>()
{
{ "auto.offset.reset", "smallest" }
}
}
}
没有 SSL 配置它工作正常,我认为我如何引用文件(密钥)本身可能有问题?尝试过的资源、嵌入的资源和内容。