Кафка авторизация

Question

Я новичок в kafka, поэтому извините, если это кажется тривиальным.

Я пытаюсь использовать аутентификацию (kerberos) и авторизацию с kafka и хотел проверить, как работает авторизация kafka. Я знаю, что по умолчанию работает через правила ACL, написанные на Zookeeper.

Я хотел знать, происходит ли проверка авторизации для каждой операции чтения / записи, т. Е. Для каждого сообщения, или это делается один раз для каждого соединения от производителя / потребителя

Answer 1

Проверки авторизации происходят при каждом запросе Kafka. Каждый раз, когда производитель отправляет сообщения в Kafka, брокеры гарантируют, что он имеет правильные списки ACL. То же самое происходит с потребителями и другими клиентами.

Если вы измените ACL, то следующий запрос будет оцениваться по обновленным правилам.

---

Аутентификация с другой стороны выполняется один раз, когда соединение установлено. В настоящее время проводится определенная работа по периодической повторной проверке подлинности для существующих подключений, которая должна быть доступна в будущем.