我正在使用 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。它等待处理未确认的消息...
如何让它使用尽可能多的资源