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

Last modified 11mo ago