KubeMQ Sources

Sources

Standalone Services

Category
Target
Kind
Configuration
Http
Http
http
Usage
Messaging
Kafka
messaging.kafka
Usage
RabbitMQ
messaging.rabbitmq
Usage
MQTT
messaging.mqtt
Usage
ActiveMQ
messaging.activemq
Usage
IBM-MQ
messaging.ibmmq
Usage
Nats
messaging.nats
Usage

Google Cloud Platform (GCP)

Category
Target
Kind
Configuration
Messaging
Pub/Sub
gcp.pubsub
Usage

Amazon Web Service (AWS)

Category
Target
Kind
Configuration
Messaging
AmazonMQ
aws.amazonmq
Usage
MSK
aws.msk
Usage
SQS
aws.sqs
Usage

Microsoft Azure

Category
Target
Kind
Configuration
EventHubs
EventHubs
azure.eventhubs
Usage
ServiceBus
azure.servicebus
Usage

Targets

Type
Kind
Configuration
Queue
kubemq.queue
Usage
Events
kubemq.events
Usage
kubemq.events-store
Usage
Command
kubemq.command
Usage
Query
kubemq.query
Usage

Middlewares

In bindings configuration, KubeMQ Bridges supports middleware setting for each pair of source and target bindings.
These properties contain middleware information settings as follows:

Logs Middleware

KubeMQ Bridges supports level based logging to console according to as follows:
Property
Description
Possible Values
log_level
log level setting
"debug","info","error"
"" - indicate no logging on this bindings
An example for only error level log to console:
1
bindings:
2
- name: sample-binding
3
properties:
4
log_level: error
5
sources:
6
......
Copied!

Retry Middleware

KubeMQ Bridges supports Retries' target execution before reporting of error back to the source on failed execution.
Retry middleware settings values:
Property
Description
Possible Values
retry_attempts
how many retries before giving up on target execution
default - 1, or any int number
retry_delay_milliseconds
how long to wait between retries in milliseconds
default - 100ms or any int number
retry_max_jitter_milliseconds
max delay jitter between retries
default - 100ms or any int number
retry_delay_type
type of retry delay
"back-off" - delay increase on each attempt
"fixed" - fixed time delay
"random" - random time delay
An example for 3 retries with back-off strategy:
1
bindings:
2
- name: sample-binding
3
properties:
4
retry_attempts: 3
5
retry_delay_milliseconds: 1000
6
retry_max_jitter_milliseconds: 100
7
retry_delay_type: "back-off"
8
sources:
9
......
Copied!
Last modified 10mo ago