kafka-connect-api 0.5.4

Apache Kafka Connect client

Documentation: https://kafka-connect-api.readthedocs.io.

Install

pip install kafka-connect-api

Usage

from kafka_connect_api.kafka_connect_api import Api, Cluster

api = Api(connect.cluster, port=8083)
cluster = Cluster(api)
print(cluster.connectors)

Features

Allows you to interact with the Kafka Connect API (API Reference) in a simple way.

• Connection to cluster (supports Basic Auth)

• List all connectors in the cluster

• Describe the connector configuration

• Update the connector configuration

• Pause / Resume Connector

• Restart all tasks for the connector

Some pre-made functions can help with operational activities. See kafka_connect_api.aws_lambdas.py