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

手順

1. Kafka 設定プロパティーファイルを編集します。

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

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

   Copy to Clipboard Toggle word wrap

   # ...
   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. デフォルトの設定ファイルで Kafka ブローカーを起動します。

   Copy to Clipboard Toggle word wrap

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

3. Kafka ブローカーが稼働していることを確認します。

   Copy to Clipboard Toggle word wrap

   jcmd | grep Kafka