第 13 章 在代理上设置吞吐量和存储限制

流程

1. 编辑 Kafka 配置属性文件。

   插件配置示例

   # ...
   client.quota.callback.class=io.strimzi.kafka.quotas.StaticQuotaCallback 

   1

   
   client.quota.callback.static.produce=1000000 

   2

   
   client.quota.callback.static.fetch=1000000 

   3

   
   client.quota.callback.static.storage.per.volume.limit.min.available.bytes=500000000000 

   4

   
   client.quota.callback.static.storage.check-interval=5 

   5

   
   client.quota.callback.static.kafka.admin.bootstrap.servers=localhost:9092 

   6

   
   client.quota.callback.static.excluded.principal.name.list=User:my-user-1;User:my-user-2 

   7

   
   # ...

   Copy to Clipboard Toggle word wrap

   1

   加载插件。

   2

   将生成者字节阈值设置为 1 MBps。

   3

   设置消费者字节阈值。1 Mbps.

   4

   将可用字节数设置为 500 GB。

   5

   将存储检查间隔（以秒为单位）设置为 5 秒。默认为 60 秒。将此属性设置为 0 以禁用检查。

   6

   Kafka 集群 bootstrap 服务器地址。如果 storage.check-interval 是 >0，则需要此属性。所有以 client.quota.callback.static.kafka.admin. 前缀开始的配置属性都传递给 Kafka Admin 客户端配置。

   7

   排除 my-user-1 和 my-user-2 的限制。每个主体都必须以 User: 前缀。

   storage.per.volume.limit.min.available.bytes 和 storage.per.volume.limit.min.available.ratio 是互斥的。仅配置其中一个参数。

   注意

   支持的配置属性的完整列表可在 插件文档 中找到。

2. 使用默认配置文件启动 Kafka 代理。

   su - kafka
   /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap

3. 验证 Kafka 代理是否正在运行。

   jcmd | grep Kafka

   Copy to Clipboard Toggle word wrap