第 12 章 管理 Kafka

流程

1. 编辑 /opt/kafka/config/server.properties Kafka 配置文件。

   该插件属性显示在本示例配置中。

   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.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 代理。

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

3. 验证 Kafka 代理是否正在运行。

   jcmd | grep Kafka