Kubemq Queue source provides a queue subscriber for processing messages from a queue
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 | |
| sources | no | set how many concurrent sources to subscribe | 1 |
| response_channel | no | set send target response to channel | "response.channel" |
| batch_size | no | set how many messages to pull from queue | "1" |