KEDA интегрируется с AWS MSK - PullRequest
Новая
       72

KEDA интегрируется с AWS MSK

0 голосов
/ 22 апреля 2020

Я использую AWS MSK, можно ли интегрироваться с Keda? Я не смог найти соответствующую документацию для AWS MSK.

1 Ответ

0 голосов
/ 04 мая 2020

Что именно вы подразумеваете под интеграцией с AWS MSK? Что вы хотите масштабировать? Кластер или Потребители?

Если вы хотите масштабировать кластер, ответ будет нет . Это не то, для чего предназначен Keda.

Наоборот, если вы хотите масштабировать потребителей, то ответ будет да , поскольку MSK - это просто управляемый (AWS) Кафка кластера, и он уже существует триггер Кафки (он же Scaler) для того, чье описание здесь . Это основано на потребительском лаге метри c. После развертывания вашего потребителя в Kubernetes все, что вам нужно сделать, это применить ScaledObject (Custom Resource), например, 

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"

Надеюсь, я помог.

...