Как можно сделать авторизацию темы в Кафке?

#.net #apache-kafka

Вопрос:

В моей системе будет несколько клиентов, темами будут клиенты, названные специальными кодами.

Где можно реализовать авторизацию тем Кафки и установить их из кода?

Например, из AdminClient можно создать тему с некоторыми настройками?

Комментарии:

1. Непонятно, почему это помечено .net … Начните здесь — kafka.apache.org/documentation/#security

2. @OneCricketeer Я пытаюсь реализовать это в .NET. Я прочитал всю их документацию, и некоторые ее части неясны.

Ответ №1:

Да, используя confluent-dotnet-kafka AdminClient, вы можете создавать темы. Конфигурации разделов могут передаваться TopicSpecification объектам, но это не включает сведения об аутентификации, так как они управляются в другом месте, не совсем на основе создания или для каждой темы. Обратитесь к примеру Github

Нет, вы не можете использовать AdminClient для указания списков управления доступом, так как это во многом зависит от authorizer.class.name настроек брокера server.properties . По умолчанию авторизатор Zookeeper использует специальный kafka-acls скрипт.

Это не исключает написания/поиска собственных Authorizer , которыми можно управлять через какой-либо HTTP-интерфейс .NET , однако, или даже с помощью вызовов оболочки .NET , которые заключают kafka-acls сценарий