0

我正在使用 Keda,基于 kubernetes 事件的自动缩放器,使用 RabbitMQ。

我有一个 scaledjob 对象配置为在观看 myQueue 时同时运行最多 30 个作业。

  pollingInterval: 10
  successfulJobsHistoryLimit: 0
  failedJobsHistoryLimit: 0
  maxReplicaCount: 30
  triggers:
    - type: rabbitmq
      metadata:
        protocol: amqp
        queueName: myQueue
        mode: QueueLength
        value: "1"
      authenticationRef:
        name: keda-trigger-auth-rabbitmq-conn

当 MyQueue 有大约 300 条消息时,没有问题。在收到 0 条消息之前,我有 30 个正在运行的作业。

但是,问题是当我在队列中有 2 条消息:1 条“Ready”和 1 条“Unacked”时,Keda 不会创建额外的 scaledjob。它等待处理未确认的消息...

如何让它使用尽可能多的资源

4

0 回答 0