半兽人你好,之前读了你的一些文章相当受益,先谢过了。现在想请教几个kafka的问题,我现在使用的kafka版本是0.10版本,单独使用配额功能时没有问题,但当我使用kafka的ssl认证后的服务之后再使用配额就发现无法对客户端进行配额控制,请问如要实现ssl认证+配额的功能应该如何实现?
还有关于配额设置的问题,我查询kafka资料发现现在配额控制只有针对主题和客户端client.id的配额设置,如果我想要实现对group.id或者ssl证书中的用户进行配额管理要如何配置呢?
半兽人你好,之前读了你的一些文章相当受益,先谢过了。现在想请教几个kafka的问题,我现在使用的kafka版本是0.10版本,单独使用配额功能时没有问题,但当我使用kafka的ssl认证后的服务之后再使用配额就发现无法对客户端进行配额控制,请问如要实现ssl认证+配额的功能应该如何实现?
还有关于配额设置的问题,我查询kafka资料发现现在配额控制只有针对主题和客户端client.id的配额设置,如果我想要实现对group.id或者ssl证书中的用户进行配额管理要如何配置呢?
客气了
1.配额失效,你使用的是kafka-configs.sh设置的配额,还是通过配置文件设置的?
2.目前kafka我只看到了根据生产者和消费者设置的配额(user, client-id)。
1.我是实用kafka-configs.sh设置的
2.我先看看谢谢。
看下这篇文章:https://www.orchome.com/510
请问你用的kafka是什么版本的,我用kafka-2.10-0.10.0.0,在输入这条命令的时候报错了
bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'producer_byte_rate=1024' --entity-type users
--entity-name clientAAA
报错信息:
Exception in thread "main" java.lang.IllegalArgumentException: --entity-type must be 'topics' or 'clients'
at kafka.admin.ConfigCommand$ConfigCommandOptions.checkArgs(ConfigCommand.scala:192)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:46)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
--entity-type clients --entity-name clientAAA
我看你这篇文章https://www.orchome.com/510里有用到 --entity-type users 这个选项
你的答案