如何将刀具事件连接到兔子外部来源

Question

我正在尝试将knative与Kubernetes集群外的现有RabbitMQ队列连接起来，但是在测试和查看文档后，我不确定是否可以做到这一点，有人知道如何使用外部RabbitMQ作为消息源使用Knative-eventing ？

问候！

Answer 1

如 knative eventing sources目录由社区开发和维护（主要来自VMware和RabbitMQ团队）。

文档和安装说明为

Answer 2

嘿，@Juan，您对我们的文档绝对是正确的，在这里，我将在审查和合并时留下PR修复部分，并有一个明确的示例有关使用外部RabbitMQ实例：

Eventing-Rabbitmq/pull/786/Files ＃
如果发现任何错误，可以对PR发表评论或在此处留下答复！

Answer 3

谢谢@sameer的回答，我认为我没有正确理解您。

访问了您给我的链接后，我启动了：

kubectl apply -filename https：//github.com/knative-sandbox/eventing-rabbitmq/releases/latest/latest/labbit/rabbitmq-source.yaml

要安装RABBITMQ源并生成秘密：

kubectl创建秘密通用rabbitmqc-default-user -n knative-eventing-from-literal = user = user = root = root -from-file =/tmp/tmp/tmp/passwork < /code>

和以下资源：

apiVersion: sources.knative.dev/v1alpha1
kind: RabbitmqSource
metadata:
  name: rabbitmq-source
  namespace: knative-eventing
spec:
  broker: "host.external.dns:5671/"
  connectionSecret:
    name: "rabbitmqc-default-user"
  user:
    secretKeyRef:
      name: "rabbitmqc-default-user"
      key: "username"
  password:
    secretKeyRef:
      name: "rabbitmqc-default-user"
      key: "password"
  exchangeConfig:
    name: "logs"
    type: "fanout"
    durable: true
    autoDelete: false
  queueConfig:
    name: "test"
    routingKey: ""
    durable: false
    autoDelete: false
  channelConfig:
    parallelism: 10
  sink:
    ref:
      apiVersion: v1
      kind: Service
      name: recorder

但是生成资源后，我会得到以下错误：

knative-sources/rabbitmq-controller-manager

│ W0524 11:45:04.108665       1 reflector.go:324] k8s.io/[email protected]/tools/cache/reflector.go:167: failed to list *v1beta1.Binding: the server could not find the requested resource (get bindings.rabbitmq.com)                                                                   │
│ E0524 11:45:04.108718       1 reflector.go:138] k8s.io/[email protected]/tools/cache/reflector.go:167: Failed to watch *v1beta1.Binding: failed to list *v1beta1.Binding: the server could not find the requested resource (get bindings.rabbitmq.com)                                 │
│ W0524 11:45:04.109915       1 reflector.go:324] k8s.io/[email protected]/tools/cache/reflector.go:167: failed to list *v1beta1.Queue: the server could not find the requested resource (get queues.rabbitmq.com)                                                                       │
│ E0524 11:45:04.109935       1 reflector.go:138] k8s.io/[email protected]/tools/cache/reflector.go:167: Failed to watch *v1beta1.Queue: failed to list *v1beta1.Queue: the server could not find the requested resource (get queues.rabbitmq.com)                                       │
│ W0524 11:45:04.109976       1 reflector.go:324] k8s.io/[email protected]/tools/cache/reflector.go:167: failed to list *v1beta1.Exchange: the server could not find the requested resource (get exchanges.rabbitmq.com)                                                                 │
│ E0524 11:45:04.109985       1 reflector.go:138] k8s.io/[email protected]/tools/cache/reflector.go:167: Failed to watch *v1beta1.Exchange: failed to list *v1beta1.Exchange: the server could not find the requested resource (get exchanges.rabbitmq.com)                              │
│ W0524 11:45:05.253806       1 reflector.go:324] k8s.io/[email protected]/tools/cache/reflector.go:167: failed to list *v1beta1.Exchange: the server could not find the requested resource (get exchanges.rabbitmq.com)                                                                 │
│ E0524 11:45:05.254035       1 reflector.go:138] k8s.io/[email protected]/tools/cache/reflector.go:167: Failed to watch *v1beta1.Exchange: failed to list *v1beta1.Exchange: the server could not find the requested resource (get exchanges.rabbitmq.com)                              │
│ W0524 11:45:05.443628       1 reflector.go:324] k8s.io/[email protected]/tools/cache/reflector.go:167: failed to list *v1beta1.Queue: the server could not find the requested resource (get queues.rabbitmq.com)

真相是我已经搜索和搜索过，我还没有找到有关如何将其连接到外部的信息兔子到Kubernetes，也许我不太了解文档。

Answer 4

此错误消息表明XXX.RABBITMQ.com CRD未安装在当前K8S群集中。

│W052411：45：04.109915 1反射器：go：324] k8s.io/<受保护] /tools/cache/reflector.go:167：无法列出 *v1beta1.queue：服务器找不到请求的资源（get queues.rabbitmq.com）│

您需要安装Rabbitqa Messaging-拓扑 - 操作员为了添加

docs ：

注意：可以使用外部兔子实例，但是如果要
使用无段资源的来源（特别是
Exchange and defue），RabbitMQ消息拓扑操作员需要
安装在与源的同一kubernetes群集中。

遵循此命令：

kubectl apply -f https://github.com/rabbitmq/messaging-topology-operator/releases/latest/download/messaging-topology-operator-with-certmanager.yaml