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

Question

我正在尝试为所有客户端将默认配额设置为0，以便最初在覆盖配额配置之前不应发送/使用任何消息。

我尝试使用下面的命令，但无法实现它。

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

有人可以解释如何实现它吗？

Answer 1

根据设计，配额不能用于阻止用户生成或消费，即使将其设置为0.它们只能用于确保用户保持在定义的吞吐量/请求率内。

要防止用户生成/使用消息，您需要使用ACL，请参阅文档中的relevent section以正确设置它们。