KubeMQ

Detailed documentation on the KubeMQ pubsub component

Component format

To setup KubeMQ pub/sub, create a component of type pubsub.kubemq. See this guide on how to create and apply a pub/sub configuration.

  1. apiVersion: dapr.io/v1alpha1
  2. kind: Component
  3. metadata:
  4. name: kubemq-pubsub
  5. spec:
  6. type: pubsub.kubemq
  7. version: v1
  8. metadata:
  9. - name: address
  10. value: localhost:50000
  11. - name: store
  12. value: false

Spec metadata fields

FieldRequiredDetailsExample
addressYAddress of the KubeMQ server“localhost:50000”
storeNtype of pubsub, true: pubsub persisted (EventsStore), false: pubsub in-memory (Events)true or false (default is false)
clientIDNName for client id connectionsub-client-12345
authTokenNAuth JWT token for connection Check out KubeMQ Authenticationew…
groupNSubscriber group for load balancingg1
disableReDeliveryNSet if message should be re-delivered in case of error coming from applicationtrue or false (default is false)

Create a KubeMQ broker

  1. Obtain KubeMQ Key by visiting https://account.kubemq.io/login/register and register for a key.
  2. Wait for an email confirmation with your Key

You can run a KubeMQ broker with Docker:

  1. docker run -d -p 8080:8080 -p 50000:50000 -p 9090:9090 -e KUBEMQ_TOKEN=<your-key> kubemq/kubemq

You can then interact with the server using the client port: localhost:50000

  1. Obtain KubeMQ Key by visiting https://account.kubemq.io/login/register and register for a key.
  2. Wait for an email confirmation with your Key

Then Run the following kubectl commands:

  1. kubectl apply -f https://deploy.kubemq.io/init
  1. kubectl apply -f https://deploy.kubemq.io/key/<your-key>

Install KubeMQ CLI

Go to KubeMQ CLI and download the latest version of the CLI.

Browse KubeMQ Dashboard

Open a browser and navigate to http://localhost:8080

With KubeMQCTL installed, run the following command:

  1. kubemqctl get dashboard

Or, with kubectl installed, run port-forward command:

  1. kubectl port-forward svc/kubemq-cluster-api -n kubemq 8080:8080

KubeMQ Documentation

Visit KubeMQ Documentation for more information.

Last modified February 16, 2023: remove trailing ``` (ea2cfd00)