如何在 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 属性。

谢谢 沙比尔