KubeMQ Bridges

Configuration

KubeMQ Bridges loads configuration file on startup. The configuration file is a yaml file that contains definitions for bindings of Sources and Targets.
The default config file name is config.yaml, and KubeMQ bridges search for this file on loading.

Structure

Config file structure:
1
bindings:
2
- name: clusters-sources # unique binding name
3
properties: # Bindings properties such middleware configurations
4
log_level: error
5
retry_attempts: 3
6
retry_delay_milliseconds: 1000
7
retry_max_jitter_milliseconds: 100
8
retry_delay_type: "back-off"
9
rate_per_second: 100
10
sources:
11
kind: source.query # Sources kind
12
name: name-of-sources # sources name
13
connections: # Array of connections settings per each source kind
14
- .....
15
targets:
16
kind: target.query # Targets kind
17
name: name-of-targets # targets name
18
connections: # Array of connections settings per each target kind
19
- .....
Copied!

Targets

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

Sources

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