KubeMQ Docs
KubeMQ.io
Login / Register
Search…
Introduction
What's New
Getting Started
Quick Start
Build & Deploy
Create Cluster
Create Dashboard
Create Connector
Message Patterns
Learn
The Basics
Message Patterns
Access Control
Clustering
Dashboard
Connectors
KubeMQ Targets
KubeMQ Sources
KubeMQ Bridges
Configuration
Cluster
Dashboard
Connectors
HOW TO
Connect Your Cluster
Show Dashboard
Get Cluster Status
Get Dashboard Status
Get Cluster Logs
Development
SDK
Cookbook
Troubleshooting
Start Here
Kubemqctl
Get Started
Create
Get
Delete
Set
Scale Cluster
Queues
Events
Events Store
Commands
Queries
Config
License
Open Source Software Notices
Powered By
GitBook
KubeMQ Bridges
KubeMQ Bridges bridge, replicate, aggregate, and transform messages between KubeMQ clusters no matter where they are, allowing to build a true cloud-native messaging single network running globally.
Key Features
:
Runs anywhere
- Kubernetes, Cloud, on-prem, anywhere
Stand-alone
- small docker container/binary
Build Any Topology
- connects KubeMQ clusters in 1:1, 1:n , n:1, n:n
Middleware Supports
- Logs, Metrics, Retries, and Rate Limiters
Easy Configuration
- simple yaml file builds your topology
An example of a use case:
use-case
Concept
KubeMQ Bridges' concept is bridging between sources and targets, thus Bindings.
Binding can be any source kinds to any target kinds, as shown below:
concept
KubeMQ Bridges can support any binding topology :
Topology
Description
Sources-Targets
Bridge
a 1:1 connectivity mainly for sync type of messages
one source to 1 target
Replicate
a 1:n connectivity allowing replicating messages between clusters
one source to n targets
Aggregate
an n:1 connectivity allowing aggregating streams fo messages from clusters to a single target
n source to 1 target
Transform
an n:n mix and match sources and targets in many to many topology
n sources to n targets
Bridge
bridge
Replicate
replicate
Aggregate
aggregate
Transform
transform
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 binding
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 of 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!
Rate Limiter Middleware
KubeMQ Sources support a Rate Limiting of target executions.
Rate Limiter middleware settings values:
Property
Description
Possible Values
rate_per_second
how many executions per second will be allowed
0 - no limitation
​
​
1 - n integer times per second
An example for 100 executions per second:
1
bindings
:
2
-
name
:
sample
-
binding
3
properties
:
4
rate_per_second
:
100
5
source
:
6
......
Copied!
Previous
KubeMQ Sources
Next - Configuration
Cluster
Last modified
1yr ago
Copy link
Contents
Concept
Bridge
Replicate
Aggregate
Transform
Middlewares
Logs Middleware
Retry Middleware
Rate Limiter Middleware