MSK
Kubemq MSK target connector allows services using kubemq server to store messages on MSK specific topics.
Prerequisites
The following are required to run the redis target connector:
kubemq cluster
MSK set up in aws
kubemq-targets deployment
Configuration
MSK source connector configuration properties:
Properties Key
Required
Description
Example
brokers
yes
MSK brokers connection, comma separated
"localhost:9092"
topic
yes
MSK stored topic
"TestTopic"
consumerGroup
yes
MSK consumer group name
"Group1
saslUsername
no
SASL based authentication with broker
"user"
saslPassword
no
SASL based authentication with broker
"pass"
Example:
bindings:
- name: kubemq-query-msk
source:
kind: kubemq.query
name: kubemq-query
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-query-msk-connector"
auth_token: ""
channel: "query.MSK"
group: ""
auto_reconnect: "true"
reconnect_interval_seconds: "1"
max_reconnects: "0"
target:
kind: aws.msk
name: aws-msk
properties:
brokers: "localhost:9092"
topic: "TestTopic"
Usage
Get Request
Get request metadata setting:
Metadata Key
Required
Description
Possible values
key
yes
MSK message key base64
"a2V5"
headers
no
MSK message headers Key Value base64
[{"Key": "ZG9n","Value": "bWV0YTE="}]
Example:
{
"metadata": {
"key": "a2V5",
"headers": [{"Key": "ZG9n","Value": "bWV0YTE="}]
},
"data": null
}
Last updated
Was this helpful?