Links

KubeMQ Targets

Targets

Standalone Services

Category
Target
Kind
Configuration
Cache
Redis
cache.redis
Usage
Memcached
cache.memcached
Usage
Hazelcast
cache.hazelcast
Usage
Stores/db
Postgres
stores.postgres
Usage
Mysql
stores.mysql
Usage
MSSql
stores.mssql
Usage
MongoDB
stores.mongodb
Usage
stores.elastic-search
Usage
Cassandra
stores.cassandra
Usage
Couchbase
stores.couchbase
Usage
stores.cockroach
Usage
Percona
stores.stores.percona
Usage
Aerospike
stores.aerospike
Usage
RethinkDB
stores.rethinkdb
Usage
Messaging
Kafka
messaging.kafka
Usage
Nats
messaging.nats
Usage
RabbitMQ
messaging.rabbitmq
Usage
MQTT
messaging.mqtt
Usage
ActiveMQ
messaging.activemq
Usage
IBM-MQ
messaging.ibmmq
Usage
Storage
Minio/S3
storage.minio
Usage
Serverless
OpenFaas
serverless.openfaas
Usage
Http
Http
http
Usage

Google Cloud Platform (GCP)

Category
Target
Kind
Configuration
Cache
Redis
gcp.cache.redis
Usage
Memcached
gcp.cache.memcached
Usage
Stores/db
Postgres
gcp.stores.postgres
Usage
Mysql
gcp.stores.mysql
Usage
BigQuery
gcp.bigquery
Usage
BigTable
gcp.bigtable
Usage
Firestore
gcp.firestore
Usage
Spanner
gcp.spanner
Usage
Firebase
gcp.firebase
Usage
Messaging
Pub/Sub
gcp.pubsub
Usage
Storage
Storage
gcp.storage
Usage
Serverless
Functions
gcp.cloudfunctions
Usage

Amazon Web Service (AWS)

Category
Target
Kind
Configuration
Stores/db
Athena
aws.athena
Usage
DynamoDB
aws.dynamodb
Usage
aws.elasticsearch
Usage
KeySpaces
aws.keyspaces
Usage
MariaDB
aws.rds.mariadb
Usage
MSSql
aws.rds.mssql
Usage
MySQL
aws.rds.mysql
Usage
Postgres
aws.rds.postgres
Usage
RedShift
aws.rds.redshift
Usage
aws.rds.redshift.service
Usage
Messaging
AmazonMQ
aws.amazonmq
Usage
MSK
aws.msk
Usage
Kinesis
aws.kinesis
Usage
SQS
aws.sqs
Usage
SNS
aws.sns
Usage
Storage
S3
aws.s3
Usage
Serverless
Lambda
aws.lambda
Usage
Other
aws.cloudwatch.logs
Usage
aws.cloudwatch.events
Usage
aws.cloudwatch.metrics
Usage

Microsoft Azure

Category
Target
Kind
Configuration
Stores/db
Azuresql
azure.stores.azuresql
Usage
Mysql
azure.stores.mysql
Usage
Postgres
azure.stores.postgres
Usage
Storage
Blob
azure.storage.blob
Usage
Files
azure.storage.files
Usage
Queue
azure.storage.queue
Usage
EventHubs
EventHubs
azure.eventhubs
Usage
ServiceBus
azure.servicebus
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:
bindings:
- name: sample-binding
properties:
log_level: error
sources:
......

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:
bindings:
- name: sample-binding
properties:
retry_attempts: 3
retry_delay_milliseconds: 1000
retry_max_jitter_milliseconds: 100
retry_delay_type: "back-off"
sources:
......