背景:我在kafka server.properties文件中设置了默认的分区数= 1和复制因子= 3,并启用了主题创建。 Kafka集群正在运行身份验证和授权。有一个主题,我只为一个用户授予了创建,读取和写入权限,权限基于主题前缀,如foo ..此用户有权从以foo开头的主题创建和消费者。现在,我想创造所有的foo。默认分区= 3和复制因子= 6的主题(这与服务器属性中的全局默认值不同)。主题创建是动态的,并且事先不知道名称。
问题:是否可以为foo类型的主题指定不同的默认分区和复制因子。*?如果不是从生产者的角度来看,实现这一目标的最佳途径是什么?
我知道KafkaAdmin的工具,但主题创建将在生产者身上进行,我不想出于安全原因向运行生产者的用户提供存储在zookeeper中的元数据的管理员权限。
谢谢!
没有这样的房产。您必须创建一些主题创建代理才能允许这样的自定义逻辑。
或者写一个Kafka改进提案(KIP),也许可以添加该功能;)