apache-kafka - 卡夫卡授权

Question

我是kafka的新手，所以如果这看起来微不足道，请原谅。

我正在尝试对 kafka 使用身份验证（kerberos）和授权，并想检查 kafka 授权的工作原理。我知道它默认通过在 Zookeeper 中编写的 ACL 规则工作。

我想知道授权检查是否发生在每个读/写操作上，即每条消息，还是每个生产者/消费者的连接都进行一次

标签： apache-kafkaapache-zookeeperacl

Answer 1

每个 Kafka 请求都会进行授权检查。每次生产者向 Kafka 发送消息时，代理都会确保它具有正确的 ACL。同样的事情也发生在消费者和其他客户身上。

如果您更改 ACL，则将根据更新的规则评估下一个请求。

---

另一方面，身份验证在建立连接时执行一次。正在进行一些工作以定期重新验证现有连接的身份验证，以便将来某个时候可用。