0

我正在尝试通过 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 配置它工作正常,我认为我如何引用文件(密钥)本身可能有问题?尝试过的资源、嵌入的资源和内容。

4

0 回答 0