Kubemq Kafka Source Connector
Kubemq kafka source connector allows services using kubemq server to access redis server. TODO
Prerequisites
The following are required to run the redis target connector:
- kubemq cluster
- kafka TODO version
- kubemq-sources deployment
Configuration
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: {}
Usage