# 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:

```yaml
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