背景: 我在我的 kafka server.properties 文件中设置了默认分区数 = 1 和复制因子 = 3,并启用了主题创建。Kafka 集群在身份验证和授权下运行。对于某些主题,我只向一个用户授予了创建、读取、写入的权限,并且权限基于诸如 foo 之类的主题前缀。. 此用户有权从以 foo 开头的主题创建和使用。现在,我想创建所有的 foo。默认分区 = 3 和复制因子 = 6 的主题(这与服务器属性中的全局默认值不同)。主题创建是动态的,事先不知道名称。
问题: 是否可以为 foo.* 类型的主题指定不同的默认分区和复制因子?如果不是,从生产者的角度来看,实现这一目标的最佳方法是什么?
我知道 KafkaAdmin 实用程序,但主题创建将发生在生产者身上,出于安全原因,我不想将 zookeeper 中存储的元数据的管理员权限授予运行生产者的用户。
谢谢!