Nats
Kubemq nats source connector allows services using kubemq server to access nats messaging services.

Prerequisites

The following are required to run the nats source connector:
  • kubemq cluster
  • nats server
  • kubemq-sources deployment

Configuration

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:
1
bindings:
2
- name: nats
3
source:
4
kind: messaging.nats
5
properties:
6
cert_file: |-
7
-----BEGIN CERTIFICATE-----
8
mycert
9
-----END CERTIFICATE-----
10
cert_key: |-
11
-----BEGIN PRIVATE KEY-----
12
mykey
13
-----END PRIVATE KEY-----
14
dynamic_mapping: "false"
15
subject: foo
16
url: nats://localhost:4222
17
target:
18
kind: kubemq.events
19
properties:
20
address: localhost:50000
21
channel: event.messaging.nats
22
dynamic_mapping: "false"
23
properties: {}
Copied!
Last modified 11mo ago