11.7. 使用 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

   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>