红帽全球峰会第 10 章 管理 Kafka
使用额外的配置属性来维护 AMQ Streams 部署。您可以添加并调整设置以响应 AMQ Streams 的性能。例如，您可以引入额外的配置来提高吞吐量和数据可靠性。
10.1. 使用 Kafka 静态配额插件在代理上设置限制
Kafka 静态配额插件只是一个技术预览。技术预览功能不包括在红帽生产服务级别协议(SLA)中，且其功能可能并不完善。红帽不推荐在生产环境中实施任何技术预览功能。此技术预览功能为您提供对即将推出的产品创新的早期访问，允许您在开发过程中测试并提供反馈。有关红帽技术预览功能支持范围的更多信息，请参阅技术预览功能支持范围。
使用 Kafka 静态配额插件在 Kafka 集群中的代理上设置吞吐量和存储限制。您可以通过在 Kafka 配置文件中添加属性来启用插件和设置限制。您可以设置字节阈值和存储配额，以在与代理交互的客户端上放置限制。
您可以为制作者和消费者带宽设置字节速率阈值。总限值分布在访问代理的所有客户端上。例如，您可以为制作者设置字节的阈值 40 MBps。如果两个制作者正在运行，则它们各自限制为 20 MBps 吞吐量。
存储配额在软限制和硬限制之间节流 Kafka 磁盘存储限制。限制适用于所有可用磁盘空间。生产者在软限制和硬限制之间逐渐下降。限制可防止磁盘填满速度超过其容量。完整磁盘可能会导致难以修复的问题。硬限制是最大存储限制。
对于 JBOD 存储，限制适用于所有磁盘。如果代理使用两个 1 TB 磁盘，且配额是 1.1 TB，一个磁盘可能会填满，而其他磁盘几乎为空。
流程
编辑
/opt/kafka/config/server.propertiesKafka 配置文件。这个示例配置中会显示插件属性。
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 # ...
使用默认配置文件启动 Kafka 代理。
su - kafka /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
验证 Kafka 代理是否正在运行。
jcmd | grep Kafka
