Har*_*ary 7 apache-kafka kafka-consumer-api
在kafka中，每当消费者尝试阅读有关其订阅者所关注主题的消息时，是否有一种方法可以对消费者进行身份验证/授权？
这里的用例是，消费者应该能够向kafka代理提供身份验证令牌，然后，代理应能够在允许消费者从主题中读取消息之前验证该令牌。
在kafka中可以实现吗？
Kafka提供可插入的身份验证和授权机制。
对于身份验证，创建自己的逻辑的过程描述如下： Kafka是否可以提供自定义LoginModule以支持LDAP？
对于授权，您只需要提供一个实现Authorizer接口的类（https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/security/auth/Authorizer.scala）并设置authorizer.class.name为的班级server.properties。
验证仅在客户端连接时执行，因此，如果您需要对每个消耗操作进行验证，则必须使用授权。
我建议您熟悉Kafka安全功能，更具体地说是授权：http：//kafka.apache.org/documentation/#security_authz
| 归档时间： |
|
| 查看次数： |
8092 次 |
| 最近记录： |