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:
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 |
|
Example:
Last updated