Description:

kafkaconnectapi 0.5.9

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

License

For personal and professional use. You cannot resell or redistribute these repositories in their original state.

Share

• Share on Facebook
• Share on Twitter