20.8. 使用 Kafka 静态配额插件设置代理限制

流程

1. 为 Kafka 资源的 config 添加插件属性。

   此示例配置中显示了插件属性。

   Kafka 静态配额插件配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     kafka:
       # ...
       config:
         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.soft: 400000000000 

   4

   
         client.quota.callback.static.storage.hard: 500000000000 

   5

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

   6

   Copy to Clipboard Toggle word wrap

   1

   加载 Kafka Static Quota 插件。

   2

   设置制作者字节阈值。本示例中为 1 Mbps.

   3

   设置消费者字节阈值。本示例中为 1 Mbps.

   4

   为存储设置较低软限制。在本示例中为 400 GB。

   5

   为存储设置更高的硬限制。本例中为 500 GB。

   6

   设置存储检查间隔（以秒为单位）。本例中有 5 秒。您可以将其设置为 0 来禁用检查。

2. 更新资源。

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap