Search code examples
c#apache-kafkaapache-kafka-security

Manage Kafka ACLs from C#

I have an application that communicates with Kafka using the C# (.NET 6) Confluent.Kafka library. It's part of a larger platform that's mostly written in Java. On the Java side org.apache.kafka.AdminClient provides ACLOperations classes to manage ACLs on the topics, but I have not been able to find something similar on the C# side.

I've been looking through the docs for Confluent.Kafka, but I don't find anything about adding or deleting ACLs. Is this even possible? EDIT: After digging in, I know that Confluent.Kafka is a wrapper for librdkafka, which only has support for manipulating ACLS in the RC releases. Is there another library (which would need to be open source and redistributable) that could be used for this?

Solution

  • Since writing this question Confluent.Kafka 1.9.0+ now supports ACL managment.