4.2.3.3. 用户配额

您可以配置 KafkaUser 资源的 spec 来强制配额,以便用户不会超过配置的 Kafka 代理访问级别。您可以设置基于大小的网络使用情况和基于时间的 CPU 使用率阈值。您还可以添加分区变异配额,以控制用户请求更改分区的请求的速率。

使用用户配额的 KafkaUser 示例

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaUser
metadata:
  name: my-user
  labels:
    strimzi.io/cluster: my-cluster
spec:
  # ...
  quotas:
    producerByteRate: 1048576 1
    consumerByteRate: 2097152 2
    requestPercentage: 55 3
    controllerMutationRate: 10 4

1
对用户可以推送到 Kafka 代理的数据量的字节每秒配额
2
对用户可从 Kafka 代理获取的数据量的字节/秒配额
3
CPU 使用率限制为客户端组的时间百分比
4
每秒允许的并发分区创建和删除操作数(参数)

有关这些属性的更多信息,请参阅 KafkaUserQuotas 架构引用