是的,Kafka在创建Topic时需要权限。Kafka集群中的每个节点都有一个或多个Broker,每个Broker都有自己的配置文件,其中包含允许创建Topic的用户和角色。
在Kafka中,有两种主要的权限:
为了创建Topic,用户需要具备相应的权限。这通常通过在Kafka的配置文件中定义用户和角色来实现。例如,可以在kafka_server_properties
文件中设置authorizer.class.name
属性来指定使用的授权器类,然后在该授权器类中定义用户和角色的权限。
另外,如果你使用的是Kafka Connect,还需要确保Connect也具备相应的权限来创建Topic。
请注意,具体的权限设置方式可能因Kafka版本和配置而有所不同。建议参考Kafka的官方文档以获取更详细的信息。