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:
1
bindings:
2
  - name: kafka
3
    source:
4
      kind: messaging.kafka
5
      properties:
6
        brokers: localhost:9092
7
        consumer_group: test_client
8
        topics: TestTopicA
9
    target:
10
      kind: kubemq.events
11
      properties:
12
        address: localhost:50000
13
        auth_token: ""
14
        channel: event.messaging.kafka
15
        client_id: test
16
    properties: {}
Copied!
Usage

Messaging

RabbitMQ

Last modified 11mo ago

Copy link

Contents

Prerequisites

Configuration

Usage