Skip to content

Latest commit

 

History

History
50 lines (42 loc) · 1.67 KB

README.md

File metadata and controls

50 lines (42 loc) · 1.67 KB

Kubemq msk Source Connector

Kubemq msk source connector allows services using kubemq server to access msk server. TODO

Prerequisites

The following are required to run the msk target connector:

  • kubemq cluster
  • active msk cluster
  • kubemq-sources deployment

Configuration

msk source connector configuration properties:

Properties Key Required Description Example
brokers yes msk brokers connection, comma separated "localhost:9092"
topics yes msk stored topic, comma separated "TestTopic"
dynamic_mapping yes set if to map msk topic to kubemq channel "true"
consumer_group yes msk consumer group name "Group1
sasl_username no SASL based authentication with broker "user"
sasl_password no SASL based authentication with broker "pass"

Example:

bindings:
  - name: kubemq-store-msk
    source:
        kind: kubemq.event-store
        name: kubemq-query
        properties:
            host: "localhost"
            port: "50000"
            client_id: "kubemq-query-aws-connector"
            auth_token: ""
            channel: "aws.msk"
            group:   ""
            auto_reconnect: "true"
            reconnect_interval_seconds: "1"
            max_reconnects: "0"
    target:
      kind: aws.msk
      name: source-aws-msk
      properties:
     	brokers: "localhost:9092,localhost:9093",
	    topic: "TestTopic",
	    consumer_group: "cg"