Необходимо настроить Авторизация с использованием ACL .
Как включить ACL:
В вашем файле server.properties
необходимо создать Authorizer
, добавив следующую строку:
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
Теперь вам нужно следовать документации, чтобы правильно настроить ACL на основе ваших вариантов использования.
Добавление списков ACL
Теперь, когда все на месте, давайте Предположим, у вас есть topi c с именем testTopic
, которому вы хотите предоставить права на чтение и запись только пользователю с именем Bob
с хоста с IP 197.5.6.1
:
bin/kafka-acls --authorizer-properties zookeeper.connect=localhost:2181 \
--add \
--allow-principal User:'Bob' --allow-host '197.5.6.1' \
--operation Read --operation Write \
--topic testTopic \