RabbitMQ

Kubemq RabbitMQ source provides a RabbitMQ subscriber for processing RabbitMQ's messages.
Prerequisites
The following are required to run events source connector:
kubemq cluster
kubemq-sources deployment
RabbitMQ Server
Configuration
RabbitMQ source connector configuration properties:
Properties Key
Required
Description
Example
url
yes
rabbitmq connection string address
"amqp://guest:[email protected]:5672/"
queue
yes
set subscription queue
"queue"
dynamic_mapping
yes
set if to map rabbit topic to kubemq channel
"true"
consumer
yes
set subscription consumer tag
"consumer"
requeue_on_error
bool
set requeue on error property
"false"
auto_ack
bool
set auto_ack property
"false"
exclusive
bool
set exclusive property
"false"
Example:
1
bindings:
2
- name: rabbitmq
3
  source:
4
    kind: messaging.rabbitmq
5
    properties:
6
      auto_ack: "false"
7
      consumer: "1"
8
      exclusive: "false"
9
      dynamic_mapping: "true"
10
      queue: some-queue
11
      requeue_on_error: "false"
12
      url: amqp://guest:[email protected]:5672/
13
  target:
14
    kind: kubemq.events
15
    properties:
16
      address: localhost:50000
17
      auth_token: ""
18
      channel: events.messaging.rabbitmq
19
      client_id: rabbitmq
20
  properties: {}
Copied!

Kafka

MQTT

Last modified 11mo ago

Copy link

Contents

Prerequisites

Configuration