Documentation: https://kafka-connect-api.readthedocs.io.
pip install kafka-connect-api
from kafka_connect_api.kafka_connect_api import Api, Cluster
api = Api(connect.cluster, port=8083)
cluster = Cluster(api)
print(cluster.connectors)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