第 10 章 管理 Kafka

流程

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

   以下示例配置中显示了插件属性。

   Kafka Static Quota 插件配置示例

   # ...
   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

   
   # ...

   Copy to Clipboard Toggle word wrap

   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

   Copy to Clipboard Toggle word wrap

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

   jcmd | grep Kafka

   Copy to Clipboard Toggle word wrap