Kafka

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-target-connectors 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
saslUsername	no	SASL based authentication with broker	"user"
saslPassword	no	SASL based authentication with broker	"pass"

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