限制主题创建/更改

Question

我有一个 3 节点不安全 kafka(v0.10.2.1) 集群，在 server.properties 中禁用了主题自动创建和删除功能

auto.create.topics.enable=false
delete.topic.enable=true

然后使用bin/kafka-topics.sh 在集群上创建/更改主题。但是，看起来任何人都可以在知道端点后在集群上创建主题。

有没有办法将主题创建/更改锁定到特定主机以防止滥用？

---

编辑 1：
由于建议使用 ACL，因此我尝试将主题创建限制为使用 kafka-acls.sh 选择主机。

将以下内容添加到server.properties 后，我重新启动了代理。

authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer                                           
allow.everyone.if.no.acl.found=true

我尝试了以下限制本地主机上的主题创建。

 bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:* --cluster --operation Create --allow-host 127.0.0.1

但是，我仍然能够使用 kafka-topics.sh 和正确的端点从其他主机创建主题。是不是没有认证就不能使用ACL？

---

Answer 1

您需要使用访问控制列表 (ACL) 来限制此类操作，这意味着知道调用者是谁，因此您首先需要通过身份验证机制来保护 kafka。

ACL：http://kafka.apache.org/documentation.html#security_authz

可以使用 SSL 或 SASL 或通过插入自定义提供程序来完成身份验证，请参阅同一文档的前面部分。

禁用自动创建不是访问控制机制，它仅意味着尝试生产或消费主题不会自动创建它。