How to enable SSL certificate in .Net Kafka consumer and producer?

Alok Gupta

Here are the code, If any iisue , Please fix or help

var config = new ConsumerConfig
{

BootstrapServers = "XXX.XX.XXX.XXX:9092", // Your Kafka broker address and SSL port
SecurityProtocol = SecurityProtocol.Ssl,
SslCaLocation = @"C:\Prod/KITTING/client.pem", // Path to your CA certificate
SslCertificateLocation = @"C:\Prod/KITTING/client-crt.pem", // Path to your client certificate
SslKeyLocation = @"C:\Prod/KITTING/pkcs8.pem", // Path to your client private key
GroupId = "my-group",
AutoOffsetReset = AutoOffsetReset.Earliest // Or other desired offset reset policy

};

1 Reply

Know the answer? Post it — somebody with the same question will find it here.

Amira Bedhiafi1y ago

Hello Alok !

You will need these PEM encoded files:

client.crt : Client Certificate
client.key or pkcs8.key : Client Private Key (must be in PKCS#8 format)
ca.crt : CA certificate (the certificate that signed the Kafka broker certificate)

var config = new ConsumerConfig
{
    BootstrapServers = "XXX.XX.XXX.XXX:9093", 
    SecurityProtocol = SecurityProtocol.Ssl,
    SslCaLocation = @"C:\Prod\KITTING\ca.crt", 
    SslCertificateLocation = @"C:\Prod\KITTING\client.crt",
    SslKeyLocation = @"C:\Prod\KITTING\client.key", 
    SslKeyPassword = "yourKeyPassword", 
    GroupId = "my-group",
    AutoOffsetReset = AutoOffsetReset.Earliest
};