Connect manager

Python client for managing the Confluent Kafka connect REST Interface.

Features

  • List, create, and delete connectors
  • Get info, status, pause, resume and restart an existing connector
  • k8s deployment via kafka-connect-manager Helm chart

Supported connectors

  • Landoop InfluxDB Sink
    • Scripted configuration
    • Dynamically check existing topics in Kafka and update the connector configuration
    • When configuring the connector skip topic names added to a blacklist

Installation

Install kafka-connect-manager:

pip install kafka-connect-manager

Project information

The main Git repository for connect-mananer is https://github.com/lsst-sqre/connect-manager

See the LICENSE file for licensing information.