我正在尝试通过ssl从.net客户端(confluent.kafka 0.9.4)连接到kafka代理,但获取accessviolationexception:尝试读取或写入受保护的内存。这通常表示其他内存已损坏。已用配置:
{
{"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配置,它可以正常工作,我想可能有问题,我如何引用文件(密钥)本身?资源、嵌入资源和内容。
暂无答案!
目前还没有任何答案,快来回答吧!