如何使用java在kafka上设置动态配额配置

uwopmtnx  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(410)

我正在尝试将所有客户端的默认配额设置为0,以便在重写配额配置之前,它们最初不应发送/使用任何消息。
我已经尝试使用下面的命令,但无法实现它。

./bin/kafka-configs.sh  
        --zookeeper <zookeeperhost> 
        --alter --add-config 'producer_byte_rate=0,consumer_byte_rate=0' 
        --entity-type clients 
        --entity-default

有人能解释一下如何做到这一点吗?

q1qsirdb

q1qsirdb1#

根据设计,配额不能用来阻止用户生产或消费,即使将其设置为0。它们只能用于确保用户保持在定义的吞吐量/请求速率内。
要防止用户生成/使用消息,需要使用ACL,请参阅文档中的相关部分以正确设置ACL。

相关问题