Queue
Kubemq Queue source provides a queue subscriber for processing source queues.
The following are required to run queue source connector:
- kubemq cluster
- kubemq-targets deployment
Queue source connector configuration properties:
Properties Key | Required | Description | Example |
address | yes | kubemq server address (gRPC interface) | kubemq-cluster:50000 |
client_id | no | set client id | "client_id" |
auth_token | no | set authentication token | jwt token |
channel | yes | set channel to subscribe | |
response_channel | no | set send target response to channel | "response.channel" |
batch_size | yes | set how many messages to pull from queue | "1" |
wait_timeout | yes | set how long to wait for messages to arrive in seconds | "60" |
Example:
bindings:
- name: kubemq-queue-elastic-search
source:
kind: queue
name: kubemq-queue
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-queue-elastic-search-connector"
auth_token: ""
channel: "queue.elastic-search"
response_channel: "queue.response.elastic"
batch_size: "1"
wait_timeout: "60"
target:
kind: stores.elastic-search
name: target-elastic-search
properties:
urls: "http://localhost:9200"
username: "admin"
password: "password"
sniff: "false"
Last modified 2yr ago