Создать пользователя

Если у вас есть ../projects/create-project.md, вы можете создать в нем пользователя Apache Kafka®.

Через CLIЧерез CLI

1. Если проект еще не создан, то создайте его: kubectl create namespace <название проекта>.

2. Создайте файл ресурса KafkaUserAccess. Например, с помощью команды touch kafkauseraccess.yaml.

3. Откройте файл и вставьте конфигурацию ниже. Создайте вместе с пользователем секрет:

   Администратор

   Потребитель

   Производитель

   apiVersion: kafka.stackland.yandex.cloud/v1alpha1
   kind: KafkaUserAccess
   metadata:
     name: kafka-user
     labels:
       kafka-cluster: cluster-omdb
   spec:
     authentication:
       username: kafka-admin
       passwordSecretRef:
         name: kafka-credentials
         key: password
     acl:
       - topic: "*"
         roles:
           - admin
   ---
   apiVersion: v1
   kind: Secret
   metadata:
     name: kafka-credentials
   type: kubernetes.io/basic-auth
   stringData:
       password: kafka-password
   ---
   

   apiVersion: kafka.stackland.yandex.cloud/v1alpha1
   kind: KafkaUserAccess
   metadata:
     name: kafka-user-consumer
     labels:
       kafka-cluster: cluster-omdb
   spec:
     authentication:
       username: kafka-consumer
       passwordSecretRef:
         name: kafka-credentials
         key: password
     acl:
       - topic: someTopic
         roles:
           - consumer
   ---
   apiVersion: v1
   kind: Secret
   metadata:
     name: kafka-credentials
   type: kubernetes.io/basic-auth
   stringData:
       password: kafka-password
   ---
   

   apiVersion: kafka.stackland.yandex.cloud/v1alpha1
   kind: KafkaUserAccess
   metadata:
     name: kafka-user-producer
     labels:
       kafka-cluster: cluster-omdb
   spec:
     authentication:
       username: kafka-producer
       passwordSecretRef:
         name: kafka-credentials
         key: password
     acl:
       - topic: someTopic
         roles:
           - producer
   ---
   apiVersion: v1
   kind: Secret
   metadata:
     name: kafka-credentials
   type: kubernetes.io/basic-auth
   stringData:
       password: kafka-password
   ---
   

4. Примените манифест: kubectl apply -f kafkauseraccess.yaml -n <название проекта>. При необходимости можно прописать название проекта в параметр ресурса metadata.namespace и не использовать в команде.

Через консоль управленияЧерез консоль управления

1. Если вы еще не открыли проект, выберите проект.
2. В левом меню выберите Kafka Clusters.
3. Выберите кластер.
4. Перейдите на вкладку Пользователи.
5. Нажмите Создать пользователя.
6. Заполните имя пользователя и пароль.
7. Нажмите Использовать паттерн под выбором топика.
8. Чтобы выбрать все топики, введите паттерн: "*".
9. Выберите роль.
10. Нажмите Создать.