MSK
Kubemq msk source connector allows services using kubemq server to access msk server. TODO

Prerequisites

The following are required to run the msk target connector:
  • kubemq cluster
  • active msk cluster
  • kubemq-target-connectors deployment

Configuration

msk source connector configuration properties:
Properties Key
Required
Description
Example
brokers
yes
msk brokers connection, comma separated
"localhost:9092"
topics
yes
msk stored topic, comma separated
"TestTopic"
dynamic_mapping
yes
set if to map msk topic to kubemq channel
"true"
consumer_group
yes
msk consumer group name
"Group1
sasl_username
no
SASL based authentication with broker
"user"
sasl_password
no
SASL based authentication with broker
"pass"
Example:
1
bindings:
2
- name: kubemq-store-msk
3
source:
4
kind: kubemq.event-store
5
name: kubemq-query
6
properties:
7
host: "localhost"
8
port: "50000"
9
client_id: "kubemq-query-aws-connector"
10
auth_token: ""
11
channel: "aws.msk"
12
group: ""
13
auto_reconnect: "true"
14
reconnect_interval_seconds: "1"
15
max_reconnects: "0"
16
target:
17
kind: aws.msk
18
name: source-aws-msk
19
properties:
20
brokers: "localhost:9092,localhost:9093",
21
topic: "TestTopic",
22
consumer_group: "cg"
Copied!
Last modified 11mo ago