在中配置Kafka。NET使用jaas

Question

我试图连接到Kafka使用汇流。Kafka包。但是，我需要使用jaas作为身份验证方法。我找不到使用融合的方法。Kafka为。NET.

编辑：

我收到以下数据连接：

bootstrap.servers=pkc.....cloud:9092
ssl.endpoint.identification.algorithm=https
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="********" password="*******";

我试图建立这样的联系：

var config = new ProducerConfig
{
    BootstrapServers = "pkc.....cloud:9092",
    SslEndpointIdentificationAlgorithm = SslEndpointIdentificationAlgorithm.Https,
    SecurityProtocol = SecurityProtocol.SaslSsl,
    SaslMechanism = SaslMechanism.Plain,
    //Jaas?***
};

你们知道我怎么设置收到的Jaas吗？

Answer 1

正如@OneCricketeer所说，JaasJava具体。我需要的只是设置用户名和密码。

最后的代码是这样的：

var config = new ProducerConfig
{
    BootstrapServers = "pkc.....cloud:9092",
    SslEndpointIdentificationAlgorithm = SslEndpointIdentificationAlgorithm.Https,
    SecurityProtocol = SecurityProtocol.SaslSsl,
    SaslMechanism = SaslMechanism.Plain,
    SaslUsername = "******",
    SaslPassword = "*****"
};