Как настроить аутентификацию SASL в Kafka?

от
prokoding.ru > Docker > Как настроить аутентификацию SASL в Kafka?

Для настройки аутентификации SASL в Kafka, необходимо выполнить следующие шаги:

  1. Установите и настройте Kafka на сервере.
  2. Установите и настройте брокер SASL и JAAS на сервере Kafka.
  3. Настройте SASL на клиентской стороне для аутентификации.

Шаг 1: Установка и настройка Kafka
-------------------------------------

  • Следуйте официальной документации Kafka для установки и настройки Kafka на вашем сервере.

Шаг 2: Установка и настройка брокера SASL и JAAS
------------------------------------------------

  • Установите и настройте Kafka SASL Broker на сервере, следуя инструкциям в документации Kafka.
  • В этом шаге вам потребуется настроить JAAS (Java Authentication and Authorization Service).
  • Создайте файл конфигурации JAAS для SASL следующим образом:
KafkaServer {
   org.apache.kafka.common.security.plain.PlainLoginModule required
   username="admin"
   password="admin-secret"
   user_admin="admin-secret";
};

В этом примере пользователь "admin" имеет пароль "admin-secret", и он находится в группе "admin". Вы можете настроить соответствующие учетные данные, подстраивая их под ваши потребности.

  • Задайте свойство sasl.mechanism.inter.broker.protocol для протокола SASL на сервере Kafka в файле конфигурации Kafka:
sasl.mechanism.inter.broker.protocol=PLAIN
  • Включите аутентификацию SASL для брокера, добавив следующую конфигурацию в файл server.properties:
advertised.listeners=SASL_PLAINTEXT://yourserver:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN

Шаг 3: Настройка SASL на клиентской стороне
-------------------------------------------

  • Для настройки аутентификации SASL на клиентской стороне вам понадобится установить и настроить JAAS для клиента.
  • Создайте файл конфигурации JAAS для клиента следующим образом:
KafkaClient {
   org.apache.kafka.common.security.plain.PlainLoginModule required
   username="admin"
   password="admin-secret";
};

Здесь указаны учетные данные, соответствующие учетным данным, указанным в настройках сервера SASL.

  • Укажите протокол SASL и механизм аутентификации в файле конфигурации потребителя или производителя Kafka:
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
  • Данный клиент сможет подключиться к серверу Kafka, проверив аутентификацию SASL, используя пользовательские учетные данные.

Это основной процесс настройки аутентификации SASL в Kafka. Обратите внимание, что приведенные выше примеры могут варьироваться в зависимости от ваших уникальных требований и конфигурации.