Kafka
Last updated
Last updated
Kubemq kafka target connector allows services using kubemq server to store messages on kafka specific topics.
The following are required to run the redis target connector:
kubemq cluster
kafka server
kubemq-targets deployment
Kafka source connector configuration properties:
Example:
Get request metadata setting:
Example:
Properties Key
Required
Description
Example
brokers
yes
kafka brokers connection, comma separated
"localhost:9092"
topic
yes
kafka stored topic
"TestTopic"
sasl_username
no
SASL based authentication with broker
"user"
sasl_password
no
SASL based authentication with broker
"pass"
Metadata Key
Required
Description
Possible values
key
yes
kafka message key base64
"a2V5"
headers
no
kafka message headers Key Value base64
[{"Key": "ZG9n","Value": "bWV0YTE="}]