Links

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:
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: {}
Last modified 2yr ago