RabbitMQ broker do not generate URL.

66 views
Skip to first unread message

Anderson Soares

unread,
Nov 25, 2021, 7:28:06 AM11/25/21
to Knative Users
Hi all,

I'm trying to create a RabbitMQ broker to use against my Azure Service bus.
So, I have done the following,:

So I have the following:
I have Kafka broker configured and working nicely.
However now I want to add the RabbitMQ broker as well.

So I installed the RabbitMQ broker via:

soareslo:~$kubectl get deployment.apps -n knative-eventing 

NAME                         READY   UP-TO-DATE   AVAILABLE   AGE

eventing-controller          1/1     1            1           7d1h

eventing-webhook             1/1     1            1           7d1h

kafka-broker-dispatcher      1/1     1            1           7d1h

kafka-broker-receiver        1/1     1            1           7d1h

kafka-controller             1/1     1            1           7d1h

kafka-webhook-eventing       1/1     1            1           7d1h

pingsource-mt-adapter        0/0     0            0           7d1h

rabbitmq-broker-controller   1/1     1            1           9m4s

rabbitmq-broker-webhook      1/1     1            1           9m4s

Then I created a secret.
With the help of this Microsoft tool https://red-mushroom-0f7446a0f.azurestaticapps.net/
I managed to convert Azure Service Bus string to RabbitMQ amqp.
 
kubectl create secret --namespace knative-eventing generic azureservicebus --from-literal=brokerURL="I PLACED THE STRING HERE"


and then created RabbitMQ broker:

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
annotations:
eventing.knative.dev/broker.class: RabbitMQBroker
name: rabbitmqbroker
namespace: default
spec:
# Configuration specific to this broker.
config:
apiVersion: v1
kind: Secret
name: azureservicebus
namespace: knative-eventing


However as you can see, the RabbitMQ Broker is not generating the URL.
Does anybody has any idea?

soareslo:~$kubectl get brokers

NAME             URL                                                                                AGE     READY   REASON

lasbroker        http://kafka-broker-ingress.knative-eventing.svc.cluster.local/default/lasbroker   7d2h    True    

rabbitmqbroker                                                                                      2m54s           


Below you can see the broker description without errors.


soareslo:~$kubectl describe broker rabbitmqbroker       

Name:         rabbitmqbroker

Namespace:    default

Labels:       <none>

Annotations:  eventing.knative.dev/broker.class: RabbitMQBroker

              eventing.knative.dev/creator: masterclient

              eventing.knative.dev/lastModifier: masterclient

API Version:  eventing.knative.dev/v1

Kind:         Broker

Metadata:

  Creation Timestamp:  2021-11-25T12:24:49Z

  Generation:          1

  Managed Fields:

    API Version:  eventing.knative.dev/v1

    Fields Type:  FieldsV1

    fieldsV1:

      f:metadata:

        f:annotations:

          .:

          f:eventing.knative.dev/broker.class:

          f:kubectl.kubernetes.io/last-applied-configuration:

      f:spec:

        .:

        f:config:

          .:

          f:apiVersion:

          f:kind:

          f:name:

          f:namespace:

    Manager:         kubectl-client-side-apply

    Operation:       Update

    Time:            2021-11-25T12:24:48Z

  Resource Version:  13195895

  UID:               003cf445-af3c-4519-8237-78e301f505f6

Spec:

  Config:

    API Version:  v1

    Kind:         Secret

    Name:         azureservicebus

    Namespace:    knative-eventing

Events:           <none>

soareslo:~$




        

Gabriel Freites

unread,
Nov 25, 2021, 8:54:56 AM11/25/21
to Anderson Soares, Knative Users

Hey Anderson,

Support for the standalone broker is been dropped so I recommend using the normal broker and following the instructions here:
eventing-rabbitmq/operator-based.md at main · knative-sandbox/eventing-rabbitmq (github.com)


Let me know if with this one things go as expected :)

--
You received this message because you are subscribed to the Google Groups "Knative Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to knative-user...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/knative-users/e82d21d5-1135-4d01-8c73-6657fd3a71a2n%40googlegroups.com.

 

Anderson Soares

unread,
Nov 25, 2021, 9:16:09 AM11/25/21
to Gabriel Freites, Knative Users
Hello Gabriel,

So I have to create my own RabbitMQ cluster in my kubernetes and then manage it by myself to be able to use the Rabbitmq broker within Knative?
Can't I just point to some external queue like I do with Kafka broker? In Kafka I just point to my kafka cluster parsing the url and it's fine, broker working however with RabbitMQ I can't, right?!
Let me know if I got it correct.


Anderson Soares | Senior Platform Engineer
skype  : anderson.soares221

Gabriel Freites

unread,
Nov 25, 2021, 9:41:24 AM11/25/21
to Anderson Soares, Knative Users

Yep, that’s exactly it. It seems that external queues are a known need for the RabbitMQ Cluster and Message Topology Operators, but is not clear when they are going to be implemented.

 

Sent from Mail for Windows

 


From: Anderson Soares <soaresan...@gmail.com>
Sent: Thursday, November 25, 2021 9:15:55 AM
To: Gabriel Freites <gfre...@vmware.com>
Cc: Knative Users <knativ...@googlegroups.com>
Subject: Re: [Suspected Spam] RabbitMQ broker do not generate URL.
 

Sameer Vohra

unread,
Dec 1, 2021, 6:15:21 PM12/1/21
to Gabriel Freites, Anderson Soares, Knative Users

Hi Anderson,

The Knative RabbitMQ Source enables pulling events from any RabbitMQ queue.

This issue provides some more context regarding the Knative RabbitMQ Broker.

 

Cheers,

Sameer

Reply all
Reply to author
Forward
0 new messages