KEDA与AWS MSK集成

Question

我正在使用AWS MSK，是否可以与Keda集成？我找不到任何有关AWS MSK的文档。

Answer 1

您所说的与AWS MSK集成到底是什么意思？您想要扩展什么？集群还是消费者？

如果您想要扩展集群，答案是no。这不是凯达的本意。

相反，如果你想扩展消费者，那么答案是yes，因为MSK只是一个托管的(由AWS) Kafka集群，它已经存在一个Kafka触发器(又称Scaler)，用于描述为here的内容。这是基于消费者滞后指标。在将消费者部署到Kubernetes上之后，您所要做的就是应用一个ScaledObject (自定义资源)，例如

apiVersion: keda.k8s.io/v1alpha1
kind: ScaledObject
metadata:
  name: kafka-scaledobject
  namespace: default
spec:
  scaleTargetRef:
    deploymentName: myDeployment # the consumer deployment you want to scale
  pollingInterval: 30
  triggers:
  - type: kafka
    metadata:
      bootstrapServers: localhost:9092
      consumerGroup: my-group       # Make sure that this consumer group name is the same one as the one that is consuming topics
      topic: test-topic
      # Optional
      lagThreshold: "50"

希望我能帮上忙。