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