第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

   
   # ...

   1

   プラグインをロードします。

   2

   プロデューサーのバイトレートしきい値を 1 MBps に設定します。

   3

   コンシューマーのバイトレートしきい値を設定します。1 MBps。

   4

   使用可能なバイト制限を 500 GB に設定します。

   5

   ストレージのチェック間隔を 5 秒に設定します。デフォルトは 60 秒です。チェックを無効にするには、このプロパティーを 0 に設定します。

   6

   Kafka クラスターブートストラップサーバーのアドレス。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 は相互に排他的です。これらのパラメーターのうち 1 つだけを設定します。

   注記

   サポートされている設定プロパティーの完全なリストは、プラグインのドキュメント に記載されています。

2. デフォルトの設定ファイルで Kafka ブローカーを起動します。

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

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

   jcmd | grep Kafka