13.7. Kafka Static Quota プラグインを使用したブローカーへの制限の設定

手順

1. Kafkaリソースのconfigにプラグインのプロパティを追加します。

   プラグインプロパティーは、この設定例のとおりです。

   Kafka Static Quota プラグインの設定例

   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-CONFIG-FILE