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​
​
​Elastic Search​
stores.elastic-search
​Usage​
​
​Cassandra​
stores.cassandra
​Usage​
​
​Couchbase​
stores.couchbase
​Usage​
​
​CockroachDB​
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​
​
​Elasticsearch​
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​
​
​RedShiftSVC​
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
​
​
​
​
​CloudWatch Logs​
aws.cloudwatch.logs
​Usage​
​
​CloudWatch Events​
aws.cloudwatch.events
​Usage​
​
​CloudWatch Metrics​
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
​
​
​
​
​ServiceBus​
azure.servicebus
​Usage​

Sources

Type
Kind
Configuration
​Queue​
kubemq.queue
​Usage​
​Events​
kubemq.events
​Usage​
​Events Store​
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:
......