如何在 Kafka 控制台 producer/consumer 中设置 Principal?
How to set Principal in Kafka console producer/consumer?
我想在 Kafka 中试验 ACL。所以我在我的 Zookeeper 中为示例主题 test 创建了一些 ACL,它允许生产者许可 User:Bob 委托人和消费者对 User:Alice 委托人的许可。
现在,当我使用 kafka-console-producer 或消费者时,如何为该生产者或消费者提及 principal?
我尝试在 producer/consumer.properties 文件中设置一个像 principal=User:Bob 这样的新配置,但它说这是一个无法识别的配置。
谁能帮我解决这个问题?
或者我是否理解了 Principal 错误的想法?这与基于 Kerberos 的身份验证有关吗?
提前致谢,
沙比尔
我通过关注博客对上述场景进行了试验,发现这里的 Principal 实际上是指 CN (Common Name) SSL 通信的属性。
Kafka 使用通信服务器的 SSL 证书的 CN 来识别 user 并相应地进行身份验证和授权。
因此,当 运行 消费者 或 制作人。它取自 SSL 证书的 CN 属性。
谢谢
沙比尔
我想在 Kafka 中试验 ACL。所以我在我的 Zookeeper 中为示例主题 test 创建了一些 ACL,它允许生产者许可 User:Bob 委托人和消费者对 User:Alice 委托人的许可。
现在,当我使用 kafka-console-producer 或消费者时,如何为该生产者或消费者提及 principal?
我尝试在 producer/consumer.properties 文件中设置一个像 principal=User:Bob 这样的新配置,但它说这是一个无法识别的配置。
谁能帮我解决这个问题? 或者我是否理解了 Principal 错误的想法?这与基于 Kerberos 的身份验证有关吗?
提前致谢, 沙比尔
我通过关注博客对上述场景进行了试验,发现这里的 Principal 实际上是指 CN (Common Name) SSL 通信的属性。
Kafka 使用通信服务器的 SSL 证书的 CN 来识别 user 并相应地进行身份验证和授权。
因此,当 运行 消费者 或 制作人。它取自 SSL 证书的 CN 属性。
谢谢 沙比尔