Skip to main content

Apache Kafka Connect client

Project description

PYPI_VERSION PyPI - License

CodeStyle TDD with pytest BDD with Behave

Documentation Status

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

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

kafka_connect_api-0.5.6.tar.gz (13.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

kafka_connect_api-0.5.6-py3-none-any.whl (14.3 kB view details)

Uploaded Python 3

File details

Details for the file kafka_connect_api-0.5.6.tar.gz.

File metadata

  • Download URL: kafka_connect_api-0.5.6.tar.gz
  • Upload date:
  • Size: 13.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.11.3 Linux/6.3.7-100.fc37.x86_64

File hashes

Hashes for kafka_connect_api-0.5.6.tar.gz
Algorithm Hash digest
SHA256 c06d1e4f6d2f3a81b1aba6ef47906a00a323b921a93b501fd4c525fb8b462508
MD5 ea72601e385b14d93e200a4ba0ddf134
BLAKE2b-256 9406825ac8366bd27d6b5733aaab83dd3afd47c7f8b082f38d9d0b464c966ad2

See more details on using hashes here.

File details

Details for the file kafka_connect_api-0.5.6-py3-none-any.whl.

File metadata

  • Download URL: kafka_connect_api-0.5.6-py3-none-any.whl
  • Upload date:
  • Size: 14.3 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.11.3 Linux/6.3.7-100.fc37.x86_64

File hashes

Hashes for kafka_connect_api-0.5.6-py3-none-any.whl
Algorithm Hash digest
SHA256 da331e731612ca5d94a0a3f11574fb5fb9bdd5687b140009cee252ad7fdd8166
MD5 1ead8eb97ca7de431f32890fea3ee48f
BLAKE2b-256 6c28908e8e10994a61c9d33f2c6e982c80edfef5b3a67350c41bd71789ef9f28

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page