Kubemq nats source connector allows services using kubemq server to access nats messaging services.
The following are required to run the nats source connector:
- kubemq cluster
- nats server
- kubemq-sources deployment
nats source connector configuration properties:
| Properties Key | Required | Description | Example |
|---|---|---|---|
| url | yes | nats connection host | "localhost:1883" |
| subject | yes | set subject name | any string |
| dynamic_mapping | yes | set if to map nats Destination to kubemq channel | "true" |
| username | no | set nats username | "username" |
| password | no | set nats password | "password" |
| token | no | set nats token | "my_token" |
| tls | no | set if tls is needed | "false","true" |
| cert_file | no | tls certificate file in string format | "my_file" |
| cert_key | no | tls certificate key in string format | "my_key" |
| timeout | no | connection timeout in seconds | "130" |
Example:
bindings:
- name: nats
source:
kind: messaging.nats
properties:
cert_file: |-
-----BEGIN CERTIFICATE-----
mycert
-----END CERTIFICATE-----
cert_key: |-
-----BEGIN PRIVATE KEY-----
mykey
-----END PRIVATE KEY-----
dynamic_mapping: "false"
subject: foo
url: nats://localhost:4222
target:
kind: kubemq.events
properties:
address: localhost:50000
channel: event.messaging.nats
dynamic_mapping: "false"
properties: {}