Kubemq kafka source connector allows services using kubemq server to access redis server. TODO
The following are required to run the redis target connector:
- kubemq cluster
- kafka TODO version
- kubemq-sources deployment
Kafka source connector configuration properties:
| Properties Key | Required | Description | Example |
|---|---|---|---|
| brokers | yes | kafka brokers connection, comma separated | "localhost:9092" |
| topics | yes | kafka stored topic, comma separated | "TestTopic" |
| dynamic_mapping | yes | set if to map kafka topic to kubemq channel | "true" |
| consumer_group | yes | kafka consumer group name | "Group1 |
| sasl_username | no | SASL based authentication with broker | "user" |
| sasl_password | no | SASL based authentication with broker | "pass" |
| sasl_mechanism | no | SASL Mechanism | SCRAM-SHA-256, SCRAM-SHA-512, plain, 0Auth bearer, or GSS-API |
| security_protocol | no | Set connection security protocol | plaintext, SASL-plaintext, SASL-SSL, SSL |
| ca_cert | no | SSL CA certificate | pem certificate value |
| client_certificate | no | SSL Client certificate (mMTL) | pem certificate value |
| client_key | no | SSL Client Key (mTLS) | pem key value |
| insecure | no | SSL Insecure (Self signed) | true / false |
Example:
bindings:
- name: kafka
source:
kind: messaging.kafka
properties:
brokers: localhost:9092
consumer_group: test_client
topics: TestTopicA
target:
kind: kubemq.events
properties:
address: localhost:50000
auth_token: ""
channel: event.messaging.kafka
client_id: test
properties: {}