---
id: kafka-connect-py
version: "1.0.0"
license: MIT
license_treatment: permissive
maintenance: aging
---

# kafka-connect-py — A client for the Confluent Platform Kafka Connect REST API.

License: permissive · Maintenance: aging · Downloads: 212.4K/mo

## What it is and what it does

kafka-connect-py is a Python client and command-line tool for interacting with Apache Kafka Connect clusters through their REST API. It wraps the Confluent Platform Kafka Connect REST interface, allowing you to manage connectors—create, update, delete, pause, resume, and inspect their status and configuration—without writing raw HTTP requests. The tool is primarily used as a CLI (invoked as `kc`) but also exposes a Python library for programmatic access.

The package depends on requests for HTTP communication and click for command-line argument parsing. It supports modern Python versions from 3.8 through 3.14 and is licensed under MIT. The repository remains active and not archived, though maintenance is aging with the last commit on 2026-01-06.

Use it for:

- Automate connector provisioning and configuration management in CI/CD pipelines for data integration workflows.
- Inspect and troubleshoot failing connectors by querying task status and connector state from the command line.
- Batch manage multiple connectors using filtering by name pattern and state (running, paused, failed, unassigned).
- Integrate Kafka Connect operations into Python scripts or orchestration tools that need programmatic cluster control.
- Monitor connector health and restart failed tasks without manual REST API calls.

## Worth the install?

AI-flagged interpretation of the facts above — verify before relying.

A command-line tool and Python client for managing Apache Kafka Connect clusters and connectors via the Kafka Connect REST API, supporting connector creation, configuration, status inspection, and lifecycle operations.

Yes, if you manage Kafka Connect clusters and prefer a CLI or Python library over raw REST calls. The low install friction, permissive MIT license, and broad Python version support make it accessible. However, the aging maintenance status warrants caution for production use—verify that the package still covers your Kafka Connect version's API surface and consider monitoring the repository for security updates or feature gaps.

## Install

pip install kafka-connect-py
uv add kafka-connect-py
poetry add kafka-connect-py

## Installing kafka-connect-py

Before you install: Low install friction with only two runtime dependencies (requests and click). Maintenance status is aging—last commit was 2026-01-06 and the package has not been updated for 220 days, though the repository remains active and not archived.

License in practice: MIT license is permissive, allowing use in both open-source and commercial projects with minimal restrictions.

Quickstart:

pip install kafka-connect-py

kc info
kc list-plugins
kc update connector-name -d '{"connector.class": "..."}'
kc status connector-name

Requires a running Kafka Connect cluster accessible via REST API; connection details must be configured (typically via environment variables or CLI flags not shown in the excerpt).

Verify before relying:

- How connection details (host, port, credentials) are configured for the CLI tool and Python API
- Whether the package supports all features of the Kafka Connect REST API as claimed, or if some remain incomplete
- Python API usage patterns beyond the command-line examples provided in the description

## Package facts

- License: MIT (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: aging
- Downloads: 212.4K/month (top 15,000 on PyPI)
- Known vulnerabilities: none known

## Tags

kafka connect cli tool, kafka connector management, kafka connect rest api client, manage kafka connectors, kafka connect python, kafka connector lifecycle, kafka connect cluster management, kafka, cli-tool, data-integration

[View on SkillFed](https://skillfed.io/packages/kafka-connect-py) · [View on PyPI](https://pypi.org/project/kafka-connect-py/)