Kafka авторизация
Я новичок в kafka, поэтому, пожалуйста, извините меня, если это кажется тривиальным.
Я пытаюсь использовать аутентификацию (kerberos) и авторизацию с помощью kafka и хотел проверить, как работает авторизация kafka. Я знаю, что по умолчанию он работает через правила ACL, написанные в Zookeeper.
Я хотел знать, выполняется ли проверка авторизации при каждой операции чтения / записи, то есть для каждого сообщения, или выполняется один раз для каждого соединения от производителя / потребителя.
Ответы 1
Проверки авторизации происходят по каждому запросу Kafka. Каждый раз, когда производитель отправляет сообщения в Kafka, брокеры проверяют наличие у него правильных списков контроля доступа. То же самое происходит с потребителями и другими клиентами.
Если вы измените ACL, то уже следующий запрос будет оцениваться на соответствие обновленным правилам.
С другой стороны, аутентификация выполняется один раз при установке соединения. В настоящее время ведется некоторая работа по периодической повторной проверке аутентификации для существующих подключений, поэтому она должна быть доступна в какой-то момент в будущем.
znodesизменилось, следовательно, можно поддерживать клиентский кеш авторизации, сохраняя синхронизацию)